报错信息如下

WARN [Consumer clientId=console-consumer, groupId=console-consumer-19763] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
^CProcessed a total of 0 messages

因为之前在配置文件中写死了ip地址,所以现在这边启动的时候不能再使用localhost作为ip地址了。

将localhos调整为配置文件中的ip即可:
1. 生产者:

./kafka-console-producer.sh --broker-list 192.168.xx.xx:9092 --topic mytest

2. 消费者:

./kafka-console-consumer.sh --bootstrap-server 192.168.xx.xx:9092 --topic mytest --from-beginning

消息收发成功
在这里插入图片描述

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐