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

Question

Я определил кластер Kafka из двух узлов с коэффициентом репликации 2. Когда я пытаюсь использовать сообщения с помощью консольного потребителя, он ничего не делает, он просто ждет.

Производитель
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic adi

Потребитель
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic adi --from-beginning

Описание кластера
Выполнение ./bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic adi визуализация:

Topic:adi       PartitionCount:1        ReplicationFactor:2   Configs:segment.bytes=1073741824        Topic: adi      Partition: 0    Leader: 3     Replicas: 3,2   Isr: 3,2

PS Все, что я сделал, это следовал Kafka Quickstart Tutorial .

Answer 1

Добавьте адрес другого брокера также в kafka-console-consumer и проверьте.

Вы, вероятно, не используете реплику лидера, попробуйте

. / Bin / kafka-console-consumer.sh --bootstrap-server localhost: 9092, другой брокер: другой порт --topic adi --от начала

Убедитесь, что вы используете prod / consumer с того же сервера, лучше использовать ip сервера вместо localhost.