Могу ли я узнать, каковы значения default.replication.factor и offsets.topic.replication.factor в ваших файлах server.properties? Речь идет не о вашей собственной теме, а о внутренней теме с именем __consumer_offset, созданной Kafka для управления смещениями фиксации.
понимаю, один из брокеров выбран в качестве координатора группы, который занимается перебалансировкой потребителей.
Discovered coordinator host:9092 (id: 2147483646 rack: null) for group good_group
У меня 3 узла с коэффициентом репликации 3 и 3 раздела. Все отлично, и когда я убиваю кафку на некоординирующих узлах, потребитель все еще получает сообщения.
Но когда я убиваю этот конкретный узел с помощью координатора, перебалансировка не происходит, и мое потребительское приложение java не получает никаких сообщений.
2018-05-29 16:34:22.668 INFO AbstractCoordinator:555 - Discovered coordinator host:9092 (id: 2147483646 rack: null) for group good_group.
2018-05-29 16:34:22.689 INFO AbstractCoordinator:600 - Marking the coordinator host:9092 (id: 2147483646 rack: null) dead for group good_group
2018-05-29 16:34:22.801 INFO AbstractCoordinator:555 - Discovered coordinator host:9092 (id: 2147483646 rack: null) for group good_group.
2018-05-29 16:34:22.832 INFO AbstractCoordinator:600 - Marking the coordinator host:9092 (id: 2147483646 rack: null) dead for group good_group
2018-05-29 16:34:22.933 INFO AbstractCoordinator:555 - Discovered coordinator host:9092 (id: 2147483646 rack: null) for group good_group.
2018-05-29 16:34:23.044 WARN ConsumerCoordinator:535 - Auto offset commit failed for group good_group: Offset commit failed with a retriable exception. You should retry committing offsets.
Я делаю что-то не так и есть ли способ обойти это?