在虚拟机中,Producer和Consumer之间能够正常通信,然后在IDEA中Producer和Consumer却无法正常生产和消费。

首先排查Kafka集群的ip和端口能够正常连接,若不能请先解决通信问题。

若ip和端口都没问题,则应该是配置问题。将kafka/config/server.properties文件中advertised.listeners改为如下属性:

advertised.listeners=PLAINTEXT://192.168.185.17:9092

192.168.185.17为kafka集群ip,9092为默认端口。

设置完直接就可以正常生产消费了。

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐