今天連搭了zookeeper和kafka的環(huan)境(jing)，并部署成(cheng)功，但在(zai).net驅動的操作(zuo)下，沒有(you)消費成(cheng)功，原因何在(zai)？

1. 防火墻
2. zookeeper沒運行？
3. kafka沒有公開IP？

第一感覺(jue)也(ye)就(jiu)是(shi)(shi)這向個(ge)原因了(le)，于是(shi)(shi)自己調試(shi)了(le)一下，最(zui)后分別進行了(le)驗證

防火墻

systemctl status firewalld

zookeeper沒運行？

netstat -tunlp|egrep 2181

kafka沒有公開IP？

$ vi server.properties

通過查看kafka的(de)(de)服務(wu)配置文件(jian)(jian)我們找到了(le)答案，它(ta)原來只公開了(le)localhost，而我們的(de)(de)程序是(shi)部署到虛(xu)擬機上的(de)(de)，所以(yi)localhost是(shi)訪(fang)問(wen)不(bu)通過的(de)(de)，即你的(de)(de)消息者(zhe)無(wu)法(fa)消費，而這(zhe)時我們需要把這(zhe)個配置文件(jian)(jian)修(xiu)改一下，把listeners的(de)(de)綁定IP添加成虛(xu)擬機真實(shi)的(de)(de)IP，然后重啟我們的(de)(de)kafka，就(jiu)可(ke)以(yi)了(le)！

bin/kafka-server-stop.sh

bin/kafka-server-start.sh config/server.properties &

最后(hou)再次進行C#客戶端(duan)的測(ce)試，令我們心(xin)喜的結果(guo)自然就出來(lai)了！

查看所有topic列表

bin/kafka-topics.sh --zookeeper localhost:2181 --list

 查看指定topic信息

bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic test

希(xi)望通過這(zhe)篇文章,讓大家對kafka,zookeepr,centos有一個(ge)學習與(yu)了解!

感謝各(ge)位的閱讀!