求助执行bin/kafka-console-producer.sh 报错

执行bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test报错：

[2017-02-03 16:17:24,305] WARN Property topic is not valid (kafka.utils.VerifiableProperties)

如下错误：
[mw_shl_code=shell,true][2017-02-03 16:19:24,370] ERROR fetching topic metadata for topics [Set(test)] from broker [ArrayBuffer(id:0,host:localhost,port:9092)] failed (kafka.utils.Utils$)
kafka.common.KafkaException: fetching topic metadata for topics [Set(test)] from broker [ArrayBuffer(id:0,host:localhost,port:9092)] failed
        at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72)
        at kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
        at kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:78)
        at kafka.utils.Utils$.swallow(Utils.scala:172)
        at kafka.utils.Logging$class.swallowError(Logging.scala:106)
        at kafka.utils.Utils$.swallowError(Utils.scala:45)
        at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:78)
        at kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
        at kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
        at kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
        at scala.collection.immutable.Stream.foreach(Stream.scala:526)
        at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
        at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
Caused by: java.net.SocketTimeoutException
        at sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.java:211)
        at sun.nio.ch.ChannelInputStream.read(ChannelInputStream.java:103)
        at java.nio.channels.Channels$ReadableByteChannelImpl.read(Channels.java:385)
        at kafka.utils.Utils$.read(Utils.scala:380)
        at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
        at kafka.network.Receive$class.readCompletely(Transmission.scala:56)
        at kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
        at kafka.network.BlockingChannel.receive(BlockingChannel.scala:111)
        at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:75)
        at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)
        at kafka.producer.SyncProducer.send(SyncProducer.scala:113)
        at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58)
        ... 12 more[/mw_shl_code]

[mw_shl_code=shell,true][root@master kafka_2.9.2-0.8.2.1]# bin/kafka-topics.sh --list --zookeeper localhost:2181
[2017-02-03 16:22:33,404] INFO Accepted socket connection from /127.0.0.1:57496 (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2017-02-03 16:22:33,408] INFO Client attempting to establish new session at /127.0.0.1:57496 (org.apache.zookeeper.server.ZooKeeperServer)
[2017-02-03 16:22:33,411] INFO Established session 0x15a02e267f60008 with negotiated timeout 30000 for client /127.0.0.1:57496 (org.apache.zookeeper.server.ZooKeeperServer)
test
[2017-02-03 16:22:33,450] INFO Processed session termination for sessionid: 0x15a02e267f60008 (org.apache.zookeeper.server.PrepRequestProcessor)
[2017-02-03 16:22:33,453] INFO Closed socket connection for client /127.0.0.1:57496 which had sessionid 0x15a02e267f60008 (org.apache.zookeeper.server.NIOServerCnxn)
[root@master kafka_2.9.2-0.8.2.1]# [/mw_shl_code]

Wyy_Ck 发表于 2017-2-3 16:24
[mw_shl_code=shell,true][root@master kafka_2.9.2-0.8.2.1]# bin/kafka-topics.sh --list --zookeeper lo ...

0.8.2.0版存在这么个问题，打个补丁试试，参考
https://issues.apache.org/jira/browse/KAFKA-1282