KafkaConnectionError: 111 ECONNREFUSED
KafkaConnectionError: 111 ECONNREFUSED
我想通过一个简单的 python 脚本生成和使用 kafka 主题。
如中所述： https://towardsdatascience.com/getting-started-with-apache-kafka-in-python-604b3250aa05 我使用 bootstrap_servers=['localhost:9092'] 创建了 publish_message 和 connect_kafka_producer 并生成了一个简单的“Hello message”，如下所示：
kafka_producer = connect_kafka_producer()
publish_message(kafka_producer, 'Hello_topic', 'Hello', "Hello")
当我尝试 运行 这个 python 函数时，我看到以下错误：
DEBUG:kafka.metrics.metrics:Added sensor with name
node-bootstrap-0.latency
DEBUG:kafka.conn:<BrokerConnection node_id=bootstrap-0
host=localhost:9092 [unspecified None]>: creating new
socket
DEBUG:kafka.conn:<BrokerConnection node_id=bootstrap-0
host=localhost:9092 [IPv4 ('127.0.0.1', 9092)]>:
setting socket option (6, 1, 1)
INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0
host=localhost:9092 [IPv4 ('127.0.0.1', 9092)]>:
connecting to localhost:9092 [('127.0.0.1', 9092) IPv4]
ERROR:kafka.conn:Connect attempt to <BrokerConnection
node_id=bootstrap-0 host=localhost:9092 [IPv4
('127.0.0.1', 9092)]> returned error 111. Disconnecting.
INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0
host=localhost:9092 [IPv4 ('127.0.0.1', 9092)]>: Closing
connection. KafkaConnectionError: 111 ECONNREFUSED
DEBUG:kafka.conn:<BrokerConnection node_id=bootstrap-0
host=localhost:9092 [IPv4 ('127.0.0.1', 9092)]>:
reconnect backoff 0.04205048432501722 after 1 failures
DEBUG:kafka.client:Give up sending metadata request since no node is
available
我的问题是，
使用“pip install kafka-python”安装 kafka-python 就足够了吗？还是需要分别下载zookeeper和kafka？
如https://www.confluent.io/blog/kafka-client-cannot-connect-to-broker-on-aws-on-docker-etc/中所述，我看不到server.properties文件将advertised.listeners更改为localhost:9092，这是因为我没有安装kafka 和我只使用“pip install kafka-python”?
I have not installed kafka
不清楚您对 produce/consume 的期望，然后
should I need to download zookeeper and kafka seperately
是的。您需要在 运行 连接到这些服务的客户端
之前安装、配置和启动服务器
我想通过一个简单的 python 脚本生成和使用 kafka 主题。 如中所述： https://towardsdatascience.com/getting-started-with-apache-kafka-in-python-604b3250aa05 我使用 bootstrap_servers=['localhost:9092'] 创建了 publish_message 和 connect_kafka_producer 并生成了一个简单的“Hello message”，如下所示：
kafka_producer = connect_kafka_producer()
publish_message(kafka_producer, 'Hello_topic', 'Hello', "Hello")
当我尝试 运行 这个 python 函数时，我看到以下错误：
DEBUG:kafka.metrics.metrics:Added sensor with name node-bootstrap-0.latency
DEBUG:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=localhost:9092 [unspecified None]>: creating new socket
DEBUG:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=localhost:9092 [IPv4 ('127.0.0.1', 9092)]>: setting socket option (6, 1, 1)
INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=localhost:9092 [IPv4 ('127.0.0.1', 9092)]>: connecting to localhost:9092 [('127.0.0.1', 9092) IPv4]
ERROR:kafka.conn:Connect attempt to <BrokerConnection node_id=bootstrap-0 host=localhost:9092 [IPv4 ('127.0.0.1', 9092)]> returned error 111. Disconnecting.
INFO:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=localhost:9092 [IPv4 ('127.0.0.1', 9092)]>: Closing connection. KafkaConnectionError: 111 ECONNREFUSED
DEBUG:kafka.conn:<BrokerConnection node_id=bootstrap-0 host=localhost:9092 [IPv4 ('127.0.0.1', 9092)]>: reconnect backoff 0.04205048432501722 after 1 failures
DEBUG:kafka.client:Give up sending metadata request since no node is available
我的问题是，
使用“pip install kafka-python”安装 kafka-python 就足够了吗？还是需要分别下载zookeeper和kafka？
如https://www.confluent.io/blog/kafka-client-cannot-connect-to-broker-on-aws-on-docker-etc/中所述，我看不到server.properties文件将advertised.listeners更改为localhost:9092，这是因为我没有安装kafka 和我只使用“pip install kafka-python”?
I have not installed kafka
不清楚您对 produce/consume 的期望，然后
should I need to download zookeeper and kafka seperately
是的。您需要在 运行 连接到这些服务的客户端
之前安装、配置和启动服务器