分享

kafka消费者kafka...

 任易x9cojw24ff 2021-06-25
问题
采用内置的zookeeper,发送端发送数据,接收端能够接收数据
但是采用外置的zookeeper,发送端发送数据,接收端一直接收不到数据
解决:
先判断主题是否一致,如果一致就在关闭kafka
./kafka-server-stop.sh ../config/server.properties
修改一下配置,确保这些配置已加上,不要用localhost,在listeners的ip地址和端口号要和消费者,生产者的的地址端口号一直
vim ../config/server.propertiesst3
在这里插入图片描述
在这里插入图片描述
最后把log.dirs后面的文件删除或者重新换个地址
rm -rf /tmp/kafka
在这里插入图片描述
重新在前台启动kafka,注意查看打印在桌面的日志,有无报错信息
./kafka-server-start.sh ../config/server.properties
如果没有报错信息,启动正常,那么就可以在后台启动了
./kafka-server-start.sh -daemon ../config/server.properties
创建生产者
./kafka-console-producer.sh --broker-list 172.16.193.175:9092 --topic test3
创建消费者
./kafka-console-consumer.sh --bootstrap-server 172.16.193.175:9092 --topic test3 --from-beginning

    本站是提供个人知识管理的网络存储空间,所有内容均由用户发布,不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息,谨防诈骗。如发现有害或侵权内容,请点击一键举报。
    转藏 分享 献花(0

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多