Когда я использую кластер Kafka с 3 узлами и версию API Kafka = 1
Я получаю следующий код ошибки = 16 Брокер возвращает этот код ошибки, если он получает выборку смещения или запрос на принятие длягруппа потребителей, для которой он не является координатором.
Но такая же настройка работает для версии API Kafka = 0.
Итак, пожалуйста, предложите мне, как решить эту проблему.