报错信息如下
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. 消费者:文章来源:https://www.toymoban.com/news/detail-638264.html
./kafka-console-consumer.sh --bootstrap-server 192.168.xx.xx:9092 --topic mytest --from-beginning
消息收发成功文章来源地址https://www.toymoban.com/news/detail-638264.html
到了这里,关于【kafka生产者启动报错】的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!