相关疑难解决方法(0)

在 RHEL v6.9 上使用 Kafka v2.1.0 的Kafka 快速入门

当 Kafka 代理之一出现故障时，消费者无法接收数据。

执行步骤：
1. 启动zookeeper
2. 启动Kafka-Server0 (localhost:9092, kafkalogs1)
3. 启动Kafka-Server1 (localhost:9094, kafkalog2)
4. 创建topic "test1", num of partitions = 1, replication factor = 2
5. 为主题“test1”运行生产者
6. 运行消费者
7. 从生产者发送消息
8. 在消费者端接收消息。

以上所有步骤都没有任何问题。

当我关闭 Kafka-Server0 时，消费者停止从生产者获取数据。当我重新启动 Kafka-Server0 时，消费者开始从它停止的地方获取消息。

这些是使用的命令

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 1 --topic test1

当我使用 --bootstrap-server 选项中指定的两个服务器运行消费者时，行为是相同的（消费者端没有收到消息）。

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092,localhost:9094 --topic test1

知道为什么即使主题 test1 …