本地Consumer和Producer无法使用远程Kafka服务器的解决方法:

分别修改各台服务器Kafka配置文件server.properties, 在#listeners=PLAINTEXT://:9092下添加如下一行:

advertised.listeners=PLAINTEXT://x.x.x.x:9092 (x.x.x.x为服务器对外的IP)

05-23 09:14