調(diào)度臺(tái)控制臺(tái) 如何利用pykafka遠(yuǎn)程消費(fèi)zookeeper kafka集群python腳本?
如何利用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需要以根用戶(hù)身份啟動(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