java 1.6上的kafka生产者错误

xuo3flqw 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(363)

我尝试在Java1.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)

同样的代码，如果我在Java1.8上运行它，它可以工作并且我能够生成消息。
你知道吗？

Java apache-kafka kafka-producer-api

来源：https://stackoverflow.com/questions/35259970/kafka-producer-error-on-java-1-6