如何使用Python从不同的服务器连接Kakfa Consumer

Question

我无法从Kafka服务器接收到我的使用者服务器的任何数据。

Kafka服务器托管在192.168.1.1中，使用者托管在192.168.1.2中使用kafka-python lib。

下面是我的例子

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的新手。

谢谢

Answer 1

您需要配置服务器（代理）以具有正确的advertised.listener。

阅读this blog，然后在此处尝试this Python code，以了解您的经纪人和客户的情况。