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