如何使用python从不同的服务器连接kakfa消费者

vlju58qv  于 2021-06-05  发布在  Kafka
关注(0)|答案(1)|浏览(340)

我无法从kafka服务器接收任何数据到我的客户服务器。
kafka服务器托管在192.168.1.1中,使用者托管在192.168.1.2中,使用kafka python库。
下面是我的例子

from kafka import KafkaConsumer

consumer = KafkaConsumer('test', bootstrap_servers=['192.168.1.1:9092'],
                     auto_offset_reset='earliest', enable_auto_commit=True,
                     auto_commit_interval_ms=1000)
for message in consumer:
    print(message);

如果我将添加错误的端口号或ip地址,它会抛出异常,这是一个很好的迹象,它连接成功,但当生产者发送数据,它将不会在192.168.1.2这个ip地址工作,但如果我尝试在192.168.1.1这个ip地址相同的工作正常。
我是否需要更改任何配置,请告诉我我是Kafka的新人。
谢谢您

unftdfkk

unftdfkk1#

您需要配置服务器(代理)以获得正确的 advertised.listener .
阅读一下这个博客,在这里尝试一下python代码,以了解您的代理和客户机发生了什么。

相关问题