apache-kafka - 无法消费来自 Kafka 集群的消息

Question

我已经定义了一个复制因子为 2 的两个节点的 Kafka 集群。当我尝试使用控制台消费者使用消息时，它什么都不做，它只是等待。

制片人
./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 快速入门教程。

标签： apache-kafkaconsumer

Answer 1

在 kafka-console-consumer 中添加另一个代理地址并检查。

您可能没有从领导者副本中消费，请尝试

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092, other-broker:other-port --topic adi --from-beginning

确保您从同一台服务器运行 prod/consumer，最好使用服务器 ip 而不是 localhost。