KafKaConnectionError：111 Econnected

Question

我想通过一个简单的python脚本产生和消费Kafka主题。如https://towardsdatascience.com/gett-start-with-apache-kafka-in-python-604b3250aa05中所述，我使用bootstrap_servers=['localhost:9092']创建了publish_message和connect_kafka_producer并生成了一个简单的“hello消息”，如下所示：

kafka_producer = connect_kafka_producer()

publish_message(kafka_producer, 'Hello_topic', 'Hello', "Hello")

当我尝试运行这个python函数时，我看到以下错误：

调试：kafka.metrics.metrics：添加名为node-bootstrap-0.latency的传感器

debug:kafka.conn: :创建新套接字

调试:kafka.conn: :设置套接字选项（6,1,1）

信息:kafka.conn: :连接到localhost:9092[('127.0.0.1',9092)IPv4]

错误：kafka.conn：尝试连接 返回错误111。断开。

信息:kafka.conn: :关闭连接。KafKaConnectionError：111 Econnected

调试:kafka.conn: :1次失败后重新连接退避0.04205048432501722

debug：kafka.client：放弃发送元数据请求，因为没有可用的节点

我的问题是，

>

使用“pip install kafka-python”安装kafka-python是否足够？还是需要单独下载zookeeper和kafka？

正如https://www.confluent.io/blog/kafka-client-nonlow-connect-to-broker-on-aws-on-docker-etc/中提到的，我不能看到server.properties文件来更改adversed.listeners到localhost:9092，这是因为我没有安装kafka，并且我只使用“PIP install Kafka-Python”吗？

Answer 1

我没有安装Kafka

不清楚你希望生产/消费什么，那么

我需要分开下载zookeeper和kafka吗