0

我对使用 kafka-python 模块的 python 中的一些代码有疑问，我真的不知道为什么它不起作用。在我使用快速入门页面建议的方法初始化 Zookeeper&Kafka 服务器并在我的计算机上创建主题后，我尝试使用 Termux 在我的智能手机上运行以下代码：

from json import dumps, loads
from kafka import KafkaProducer, KafkaConsumer

class CommunicationLayer:

def __init__(self, node_id):
self.output_publisher = KafkaProducer(bootstrap_servers=['192.168.1.103:9092'], value_serializer=lambda x:
dumps(x).encode('utf-8'))

self.window_receiver = KafkaConsumer("node_{}".format(node_id), bootstrap_servers=['192.168.1.103:9092'] , value_deserializer=lambda x: loads(x.decode('utf-8')))
...
(code  that doesn't really help)
...

（IP指向运行kafka服务器的机器）。运行此代码后，我会立即收到 NoBrokerAvailable 错误，据我所知，该错误仅在您尚未初始化服务器时出现。我错过了什么吗？

4

1 回答 1

0

我尝试在我的智能手机上运行以下代码

注意：Kafka 客户端不适合在网络连接不可靠的环境中运行。

IP指向运行kafka服务器的机器

ZooKeeper和 Kafka 是否在这台机器上暴露在外部，而不仅仅是在本地监听？

同样，您需要将advertised.listenersKafka 属性中的属性设置为该外部地址，以便任何客户端能够在引导连接后实际连接。

于 2019-03-22T19:27:49.863 回答