我无法从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的新人。
谢谢您
1条答案
按热度按时间unftdfkk1#
您需要配置服务器(代理)以获得正确的
advertised.listener
.阅读一下这个博客,在这里尝试一下python代码,以了解您的代理和客户机发生了什么。