kafka生产者消费者报错Connection to node -1 could not be established. Broker may not be available.
本文共 607 字，大约阅读时间需要 2 分钟。
问题
kafka执行生产者和消费者命令报错
[root@hadoop89 bin]# kafka-console-producer.sh --broker-list 192.168.159.89:6668 --topic article_topic_1[2021-06-15 11:01:24,411] WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
原因
查看kafka的配置文件
cd $KAFKA_HOME/conf vi server.properties
端口不是9092 是6667 解决办法
执行生产者消费者命令时把端口改为6667
启动生产者 kafka-console-producer.sh --broker-list 192.168.159.89:6667 --topic article_topic_1启动消费者kafka-console-consumer.sh --bootstrap-server 192.168.159.89:6667 --topic topic_test1 --from-beginning
转载地址：http://rduzi.baihongyu.com/
你可能感兴趣的文章
MFC CListBox的使用
查看>>
VS2008向MFC 对话框 添加托盘图标(显示和消失)
查看>>
redhat中vsftp开机自启动
查看>>
MySQL存储过程,生成大量数据
查看>>
查询字段值出现多次的字段值
查看>>
SQL Server表存在则进行查重 SQL语句
查看>>
redhat 9 下sqlite 3的安装及编程
查看>>
两个同步表的字段复制.Oracle.
查看>>
windows MySQL 报“Got a packet bigger than 'max_allowed_packet' bytes”错误，解决过程.
查看>>
在Redhat9下静态编译glib库.
查看>>
CImg库编译使用.
查看>>
SQL Server循环执行动态SQL语句.
查看>>
ubuntu10.4网卡名由eth0改为eth4，导致获得不了IP地址.解决方法.
查看>>
CheckPoint关键词做字段名使用.
查看>>
Qt QSplitte分割器使用（用户手动改变窗口大小）
查看>>
Qt动态加载动态库
查看>>
java8新特性
查看>>
git clone时RPC failed; curl 18 transfer closed with outstanding read data remaining
查看>>
Java8内存模型—永久代(PermGen)和元空间(Metaspace)
查看>>
maven中jar、war、pom的区别
查看>>