Когда экземпляр потребителя кафки меняет group.id, динамически, когда сервер перезагружается

Question

Когда экземпляр потребителя kafka перезапускается и когда его потребитель group.id меняется при каждом перезапуске.Хорошо ли такое поведение или оно повлияет на производительность kafka?

Какое значение мы можем предоставить для свойств 'log.retention.ms'.

Answer 1

В этом случае (изменение идентификатора группы после каждого перезапуска) очень хорошо приведет к повторной обработке ваших прошлых данных.Это желаемое поведение?

Обычно group.id остается неизменным после перезапуска потребителя, чтобы сохранить смещения для группы.В противном случае вновь созданная группа потребителей (после перезапуска) продолжит обработку в отношении параметра конфигурации auto.offset.reset.

Сохранение идентификатора group.id аналогично стандартному поведению.