0

我正在尝试在 java 1.6 上运行 kafka 生产者，我使用的是 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 上运行相同的代码，它可以工作并且我能够生成消息。

任何想法 ？

4

1 回答 1

0

问题是网络问题，修复日志记录后，我能够读取正确的错误、网络超时并修复它。

于 2016-02-08T13:58:45.030 回答