W1ngs
W1ngs
2017-10-25 14:12

kafka自定义producer链接topic错误

5
  • kafka 消息发布与订阅

kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
[2017-10-25 22:02:15,757] ERROR Failed to send requests for topics xutongtp with correlation ids in 0,12
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:98)
at kafka.producer.Producer.send(Producer.scala:78)
at kafka.javaapi.producer.Producer.send(Producer.scala:35)
at kafka.transwarp.io.KafkaProducer.produce(KafkaProducer.java:34)
at kafka.transwarp.io.KafkaMain.main(KafkaMain.java:7)

  • 点赞
  • 回答
  • 收藏
  • 复制链接分享

1条回答

为你推荐

换一换