51工具盒子

依楼听风雨
笑看云卷云舒,淡观潮起潮落

kafka消费者发送消息失败

报错信息:Failed to send messages after 3 tries.

[2020-03-30 06:53:28,302] ERROR Error in handling batch of 1 events (kafka.producer.async.ProducerSendThread)
kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
    at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)
    at kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:104)
    at kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:87)
    at kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:67)
    at scala.collection.immutable.Stream.foreach(Stream.scala:526)
    at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:66)
    at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44)

解决方法:

advertised.host.name=192.168.230.101
advertised.port=9092
zookeeper.connect=192.168.230.101:2181

在server.properties文件中添加或修改。192.168.230.101为kafkaIP

赞(0)
未经允许不得转载:工具盒子 » kafka消费者发送消息失败