kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.

2018/7/30 posted in  Kafka

Kafka版本是 2.11-1.0.1

今天用Java操作Kafka,生产者的时候,报

Exception in thread "main" Failed to send requests for topics test with correlation ids in [0,3]
kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.

的异常,在网上查了,需要找到Kafka安装目录的config目录下的server.properties文件,找到advertised.listeners这行,把

#advertised.listeners=PLAINTEXT://your.host.name:9092

改为

advertised.listeners=PLAINTEXT://IP:9092

然后重启Kafka,就可以了。