文章出處
文章列表
今天連搭了zookeeper和kafka的環境，并部署成功，但在.net驅動的操作下，沒有消費成功，原因何在？
- 防火墻
- zookeeper沒運行？
- kafka沒有公開IP？
第一感覺也就是這向個原因了，于是自己調試了一下，最后分別進行了驗證
防火墻
systemctl status firewalld
zookeeper沒運行？
netstat -tunlp|egrep 2181
kafka沒有公開IP？
$ vi server.properties
通過查看kafka的服務配置文件我們找到了答案，它原來只公開了localhost，而我們的程序是部署到虛擬機上的，所以localhost是訪問不通過的，即你的消息者無法消費，而這時我們需要把這個配置文件修改一下，把listeners的綁定IP添加成虛擬機真實的IP，然后重啟我們的kafka，就可以了！
bin/kafka-server-stop.sh
bin/kafka-server-start.sh config/server.properties &
最后再次進行C#客戶端的測試，令我們心喜的結果自然就出來了！
查看所有topic列表
bin/kafka-topics.sh --zookeeper localhost:2181 --list查看指定topic信息
bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test希望通過這篇文章,讓大家對kafka,zookeepr,centos有一個學習與了解!
感謝各位的閱讀!
文章列表
全站熱搜
留言列表
