pykafka客户端连接错误的代理

5lhxktic  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(642)

我搞不清楚发生了什么事。
我通过运行以下命令启动producer:

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

消费者:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

但当我这么做的时候

client = KafkaClient('localhost:9092')

它总是说: Failed to connect newly created broker for b'adnans-mbp':9092 ```
Error encountered when producing to broker b'adnans-mbp':9092. Retrying.
Error encountered when producing to broker b'adnans-mbp':9092. Retrying.

在发送信息时,我在程序中一无所获。虽然在控制台上它正在接收消息。
我怎么了?
6jygbczu

6jygbczu1#

查看 listeners 中的属性 server.properties 配置文件。它看起来像你的 KafkaClient 示例无法与您正在本地运行的代理通信,可能是由于主机名转换正在进行 localhost 进入 adnans-mbp .
另请参见https://github.com/parsely/pykafka/issues/812

相关问题