Невозможно отправить сообщение от производителя к потребителю

Question

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

Сообщение не передается от производителя к потребителю.

Answer 1

Сценарий потребителя:

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

Сценарий производителя:

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

В вышеприведенных командах адреса брокеров различны.Кажется, что у продюсера правильный адрес localhost:9092, а у сценария потребителя - адрес зоопарка localhost:2181.Измените его на localhost:9092 вот так ::

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

Answer 2

Команды, необходимые для запуска производителя и потребителя:

Cosumer :

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

Производитель

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

Если вы хотите использовать сообщения с самого начала, включите --from-beginning в качестве потребителя, в противном случае он будет использовать последние сообщения по умолчанию.

Если вы добавите больше брокеров в свой кластер,чтобы потреблять / производить от всех брокеров, просто добавьте порты ваших брокеров как: localhost:9092,localhost:9093,localhost:9094

Answer 3

У потребителя вы по ошибке использовали порт zookeeper 2181. Он должен быть localhost:9092