报错信息如下

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

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

更多推荐