bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test运行失败

发布于 2021-11-29 19:45:11 字数 5710 浏览 991 评论 1

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 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

等风来 2021-11-29 22:48:52

kafka没启动成功

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文