如何利用pykafka遠(yuǎn)程消費(fèi)zookeeper kafka集群python腳本？請(qǐng)參閱文檔https://pykafka.readthedocs.io/en/latest/index.htmlkaf

如何利用pykafka遠(yuǎn)程消費(fèi)zookeeper kafka集群python腳本？

請(qǐng)參閱文檔https://pykafka.readthedocs.io/en/latest/index.html

kafka默認(rèn)端口？

卡夫卡默認(rèn)端口號(hào)：9092改為19092

端口號(hào)可以任意修改。如果端口號(hào)設(shè)置為小于1024，則Kafka需要以根用戶身份啟動(dòng)。

[下一步

1服務(wù)屬性端口=19092，如果未指定，按照默認(rèn)值9092

2-分布式.propertiesbootstrap.servers=本地主機(jī):19092

3、 生產(chǎn)商屬性bootstrap.servers=本地主機(jī)：19092

4、連接-獨(dú)立.propertiesbootstrap.servers=本地主機(jī):19092

5、 消費(fèi)者財(cái)產(chǎn)bootstrap.servers=本地主機(jī):19092