логе появилась ошибка:
[2019-10-30 12:07:27,906] INFO [GroupCoordinator 1]: Stabilized group service-group-PROD generation 3600 (__consumer_offsets-12) (kafka.coordinator.group.GroupCoordinator)
[2019-10-30 12:07:27,908] INFO [GroupCoordinator 1]: Assignment received from leader for group service-group-PROD for generation 3600 (kafka.coordinator.group.GroupCoordinator)
[2019-10-30 12:07:28,966] INFO [GroupCoordinator 1]: Preparing to rebalance group service-group-PROD in state PreparingRebalance with old generation 3600 (__consumer_offsets-12) (reason: Adding new member service-group-PROD-ff9fdf88d-47d5q-3a61ab0d-7f19-44b1-87b3-edf0bee9d25a with group instanceid None) (kafka.coordinator.group.GroupCoordinator)
подскажите как это можно пофиксить?
а где ошибка?
Решилась проблема обновлением до 2.3.1. Бага описана тут - https://issues.apache.org/jira/browse/KAFKA-8653
Обсуждают сегодня