调度台控制台 如何利用pykafka远程消费zookeeper kafka集群python脚本?

如何利用pykafka远程消费zookeeper kafka集群python脚本?请参阅文档https://pykafka.readthedocs.io/en/latest/index.htmlkaf

如何利用pykafka远程消费zookeeper kafka集群python脚本?

请参阅文档https://pykafka.readthedocs.io/en/latest/index.html

kafka默认端口?

卡夫卡默认端口号:9092改为19092

端口号可以任意修改。如果端口号设置为小于1024,则Kafka需要以根用户身份启动。

[下一步

1服务属性端口=19092,如果未指定,按照默认值9092

2-分布式.propertiesbootstrap.servers=本地主机:19092

3、 生产商属性bootstrap.servers=本地主机:19092

4、连接-独立.propertiesbootstrap.servers=本地主机:19092

5、 消费者财产bootstrap.servers=本地主机:19092