PyKafka 客户端连接错误的代理
PyKafka client connecting wrong broker
我无法弄清楚发生了什么。
我通过 运行 命令启动了生产者：
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.
在发送消息时，我在程序中什么也得不到。尽管在控制台上它正在接收消息。
我这是怎么了？
检查 server.properties 配置文件中的 listeners 属性。看起来您的 KafkaClient 实例无法与您在本地 运行 的代理通信，这可能是由于主机名转换将 localhost 转换为 adnans-mbp.
我无法弄清楚发生了什么。
我通过 运行 命令启动了生产者：
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.
在发送消息时，我在程序中什么也得不到。尽管在控制台上它正在接收消息。
我这是怎么了？
检查 server.properties 配置文件中的 listeners 属性。看起来您的 KafkaClient 实例无法与您在本地 运行 的代理通信，这可能是由于主机名转换将 localhost 转换为 adnans-mbp.