Случайное поведение потребителя и координатора группы Kafka при исключении из группы потребителей ⇐ JAVA

[Anonymous]

В настоящее время у меня есть два экземпляра одного и того же приложения, работающие в двух средах (назовем их экземпляром 1 и экземпляром 2). Эти экземпляры потребляют сообщения от Kafka (разных брокеров Kafka). В журналах обоих экземпляров я вижу следующую ошибку от ConsumerCoordinator

Код: Выделить всё

[ERROR] o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=csp.hk, groupId=csp.hk] Asynchronous auto-commit of offsets failed: Offset commit cannot be completed since the consumer is not part of an active group for auto partition assign
ment; it is likely that the consumer was kicked out of the group.. Will continue to join group.

[WARN ] o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=csp.hk, groupId=csp.hk] Asynchronous auto-commit of offsets /*many topic partitions*/ failed: Offset commit cannot be completed since the consumer is not part of an active group for auto partition assignment; it is likely that the consumer was kicked out of the group.

Однако в примере 1 я также вижу повторную попытку сразу после исключения.

Код: Выделить всё

 [INFO ] o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=csp.hk, groupId=csp.hk] Request joining group due to: need to re-join with the given member-id: csp.hk-0e3f111c-8a92-49c3-81dc-61c4c5956df7
[INFO ] o.a.k.c.c.i.ConsumerCoordinator - [Consumer clientId=csp.hk, groupId=csp.hk] (Re-)joining group

Экземпляр 2 не предпринимает никаких попыток. Потребитель никогда повторно не присоединяется к группе, и поэтому все будущие сообщения игнорируются/не потребляются.
Кажется, я не могу понять, почему существует разница в поведении. Оба приложения должны использовать одни и те же потребительские свойства Kafka. Может ли кто-нибудь помочь с этим?
Я буду рад предоставить дополнительную информацию, если это поможет.


Подробнее здесь: https://stackoverflow.com/questions/788 ... -out-of-of