HDP里面Kafka部署完后,使用java程序给kafka发送数据会报错,具体的错误信息如下,
WARN kafka.producer.async.DefaultEventHandler:89 - Failed to send producer request with correlation id 2 to broker 1002 with data for partitions [test,0]
注意id=2这个是不定的,等于其他值也有可能。
具体解决从这个link找到
https://stackoverflow.com/questions/28146409/kafka-unable-to-send-a-message-to-a-remote-server-using-java
修改kafka的server.properties增加以下内容即可
advertised.host.name=<Kafka Running Machine IP>