我搞不清楚发生了什么事。
我通过运行以下命令启动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.
在发送信息时,我在程序中一无所获。虽然在控制台上它正在接收消息。
我怎么了?
1条答案
按热度按时间6jygbczu1#
查看
listeners
中的属性server.properties
配置文件。它看起来像你的KafkaClient
示例无法与您正在本地运行的代理通信,可能是由于主机名转换正在进行localhost
进入adnans-mbp
.另请参见https://github.com/parsely/pykafka/issues/812