java 1.6 上的 Kafka 生产者错误

Question

我正在尝试运行 java 1.6 上的 kafka 生产者，我使用的是 0.8.1.1 版。它是运行ning 但是当它尝试发送消息时它给出

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 上有效并且我能够生成消息。

有什么想法吗？

Answer 1

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

java 1.6 上的 Kafka 生产者错误

Kafka Producer error on java 1.6

java

apache-kafka

kafka-producer-api