windows - 无法从生产者向消费者发送消息

Question

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

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

标签： windowsapache-kafkaapache-zookeeperkafka-producer-api

Answer 1

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

消费者：

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

制片人

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

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

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