【发布时间】:2016-02-08 21:58:45
【问题描述】:
我正在尝试在 java 1.6 上运行 kafka producer,我使用的是 0.8.1.1 版本。它正在运行,但是当它尝试发送它给出的消息时
Exception in thread "Main" kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)
at kafka.producer.Producer.send(Producer.scala:76)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
如果我在 java 1.8 上运行相同的代码,它可以工作并且我能够生成消息。
有什么想法吗?
【问题讨论】:
标签: java apache-kafka kafka-producer-api