Кафка не может получить компенсацию, когда 1 из 3 брокеров не работает - PullRequest
1 голос
/ 18 июня 2019

У меня работает 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
    (...)

Есть идеи, почему я получаю ошибку "Не удалось получить смещения"?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...