无法从生产者向消费者发送消息答案

【问题标题】：Unable to send message from Producer to Consumer无法从生产者向消费者发送消息
【发布时间】：2019-05-20 19:57:12
【问题描述】：

kafka-console-consumer.bat --bootstrap-server localhost:2181 --topic baeldung kafka-console-producer.bat --broker-list localhost:9092 --topic baeldung

消息不会从生产者传递到消费者。

【问题讨论】：

投票结束为错字。 2181 => 9092

标签： windows apache-kafka apache-zookeeper kafka-producer-api

【解决方案1】：

运行生产者和消费者所需的命令：

消费者：

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic baeldung

制片人

kafka-console-producer.bat --broker-list localhost:9092 --topic baeldung

如果要从头开始消费消息，在consumer中包含--from-beginning，否则默认消费最新消息。

如果您向集群添加更多代理，为了从所有代理消费/生产，只需添加您的代理端口，例如：localhost:9092,localhost:9093,localhost:9094

【讨论】：

【解决方案2】：

消费者脚本：

kafka-console-consumer.bat --bootstrap-server localhost:2181 --topic 呸呸呸

制片人脚本：

kafka-console-producer.bat --broker-list localhost:9092 --topic 呸呸呸

在上述命令中，代理地址是不同的。生产者似乎有正确的地址localhost:9092，而消费者脚本有动物园管理员地址localhost:2181。像这样把它改成localhost:9092 ::

kafka-console-consumer.bat --bootstrap-server localhost:9092--topic baeldung

【讨论】：

【解决方案3】：

在消费者中你错误地使用了zookeeper端口2181。它必须是localhost:9092

【讨论】：

如果改用--zookeeper localhost:2181，那么它可能会起作用，但我相信在删除了该支持的最新版本中不会。在早期版本中，还需要添加 --new-consumer 选项，该选项是在 0.10 版本左右添加的
是的，我认为它是较新的版本之一。