bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test运行失败
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test [2016-08-22 01:06:00,875] WARN Property topic is not valid (kafka.utils.VerifiableProperties) [2016-08-22 01:06:40,220] WARN Error while fetching metadata partition 0 leader: none replicas: isr: isUnderReplicated: false for topic partition [test,0]: [class kafka.common.LeaderNotAvailableException] (kafka.producer.BrokerPartitionInfo) [2016-08-22 01:06:40,227] WARN Failed to collate messages by topic,partition due to: No leader for any partition in topic test (kafka.producer.async.DefaultEventHandler) [2016-08-22 01:06:40,333] WARN Error while fetching metadata partition 0 leader: none replicas: isr: isUnderReplicated: false for topic partition [test,0]: [class kafka.common.LeaderNotAvailableException] (kafka.producer.BrokerPartitionInfo) [2016-08-22 01:06:40,333] WARN Failed to collate messages by topic,partition due to: No leader for any partition in topic test (kafka.producer.async.DefaultEventHandler) [2016-08-22 01:06:40,438] WARN Error while fetching metadata partition 0 leader: none replicas: isr: isUnderReplicated: false for topic partition [test,0]: [class kafka.common.LeaderNotAvailableException] (kafka.producer.BrokerPartitionInfo) [2016-08-22 01:06:40,439] WARN Failed to collate messages by topic,partition due to: No leader for any partition in topic test (kafka.producer.async.DefaultEventHandler) [2016-08-22 01:06:40,544] WARN Error while fetching metadata partition 0 leader: none replicas: isr: isUnderReplicated: false for topic partition [test,0]: [class kafka.common.LeaderNotAvailableException] (kafka.producer.BrokerPartitionInfo) [2016-08-22 01:06:40,544] WARN Failed to collate messages by topic,partition due to: No leader for any partition in topic test (kafka.producer.async.DefaultEventHandler) [2016-08-22 01:06:40,648] WARN Error while fetching metadata partition 0 leader: none replicas: isr: isUnderReplicated: false for topic partition [test,0]: [class kafka.common.LeaderNotAvailableException] (kafka.producer.BrokerPartitionInfo) [2016-08-22 01:06:40,650] ERROR Failed to send requests for topics test with correlation ids in [0,8] (kafka.producer.async.DefaultEventHandler) [2016-08-22 01:06:40,651] ERROR Error in handling batch of 1 events (kafka.producer.async.ProducerSendThread) kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries. at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90) 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:547) at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67) at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45) [2016-08-22 01:06:41,655] WARN Failed to collate messages by topic,partition due to: No leader for any partition in topic test (kafka.producer.async.DefaultEventHandler) [2016-08-22 01:06:41,759] WARN Error while fetching metadata partition 0 leader: none replicas: isr: isUnderReplicated: false for topic partition [test,0]: [class kafka.common.LeaderNotAvailableException] (kafka.producer.BrokerPartitionInfo) [2016-08-22 01:06:41,760] WARN Failed to collate messages by topic,partition due to: No leader for any partition in topic test (kafka.producer.async.DefaultEventHandler) [2016-08-22 01:06:41,865] WARN Error while fetching metadata partition 0 leader: none replicas: isr: isUnderReplicated: false for topic partition [test,0]: [class kafka.common.LeaderNotAvailableException] (kafka.producer.BrokerPartitionInfo) [2016-08-22 01:06:41,865] WARN Failed to collate messages by topic,partition due to: No leader for any partition in topic test (kafka.producer.async.DefaultEventHandler) [2016-08-22 01:06:41,969] WARN Error while fetching metadata partition 0 leader: none replicas: isr: isUnderReplicated: false for topic partition [test,0]: [class kafka.common.LeaderNotAvailableException] (kafka.producer.BrokerPartitionInfo) [2016-08-22 01:06:41,970] WARN Failed to collate messages by topic,partition due to: No leader for any partition in topic test (kafka.producer.async.DefaultEventHandler) [2016-08-22 01:06:42,074] WARN Error while fetching metadata partition 0 leader: none replicas: isr: isUnderReplicated: false for topic partition [test,0]: [class kafka.common.LeaderNotAvailableException] (kafka.producer.BrokerPartitionInfo) [2016-08-22 01:06:42,075] ERROR Failed to send requests for topics test with correlation ids in [9,16] (kafka.producer.async.DefaultEventHandler) [2016-08-22 01:06:42,075] ERROR Error in handling batch of 1 events (kafka.producer.async.ProducerSendThread) kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries. at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90) 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:547) at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67) at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
kafka没启动成功