0
我想在java 1.6上運行卡夫卡生產者,我使用的是版本0.8.1.1。它正在運行,但是,當它試圖將消息發送給它關於java的卡夫卡生產者錯誤1.6
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它的工作原理運行它,我能夠產生消息。
有什麼想法?