У меня работает 3 брокера Kafka. Во всех моих темах коэффициент репликации установлен на 2. Когда я выключаю одного из брокеров, кластер Kafka, насколько я понимаю, должен продолжать работать, но по какой-то причине это не так.
Например, я не могу запустить следующий скрипт, который работает нормально, когда все брокеры живы.
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group myGroup --describe
Note: This will not show information about old Zookeeper-based consumers.
Error: Executing consumer group command failed due to Failed to get offsets by times in 305000ms
Системный раздел, содержащий смещения (__consumer_offsets), также правильно реплицируется. Брокер 1 не работает, но все еще есть хотя бы одна здоровая реплика.
./kafka-topics.sh --zookeeper localhost --topic __consumer_offsets --describe
Topic:__consumer_offsets PartitionCount:50 ReplicationFactor:2 Configs:segment.bytes=104857600,cleanup.policy=compact,compression.type=producer
Topic: __consumer_offsets Partition: 0 Leader: 3 Replicas: 3,1 Isr: 3
Topic: __consumer_offsets Partition: 1 Leader: 2 Replicas: 1,2 Isr: 2
Topic: __consumer_offsets Partition: 2 Leader: 2 Replicas: 2,3 Isr: 3,2
Topic: __consumer_offsets Partition: 3 Leader: 3 Replicas: 3,2 Isr: 2,3
Topic: __consumer_offsets Partition: 4 Leader: 3 Replicas: 1,3 Isr: 3
Topic: __consumer_offsets Partition: 5 Leader: 2 Replicas: 2,1 Isr: 2
Topic: __consumer_offsets Partition: 6 Leader: 3 Replicas: 3,1 Isr: 3
Topic: __consumer_offsets Partition: 7 Leader: 2 Replicas: 1,2 Isr: 2
Topic: __consumer_offsets Partition: 8 Leader: 2 Replicas: 2,3 Isr: 3,2
(...)
Есть идеи, почему я получаю ошибку "Не удалось получить смещения"?