где-то уже обсуждалось - направьте, пожалуйста.
1. Запускаю простое приложение, которое пишет сообщения в кафку быстрее, чем читает. Версия приложения - 0.1, подхватывается кафкой и присваивается в кач-ве названия консьюмер группы;
2. Останавливаю приложение. Поднимаю его версию до 0.2 и запускаю. Создаётся новая консьюмер группа, а не успевшие попасть в консьюмер сообщения с прошлого раза так и остаются висеть в очереди. В итоге:
consumer group -- state -- overall lag
kafkaapp-v0.1 -- - -- 21585
kafkaapp-v0.2 -- Active -- -
Причина понятна: https://stackoverflow.com/questions/58928487/kafka-consumer-not-consuming-from-beginning
Одно из путей решения - это сбросить оффсет группы. Не заставит ли это кафку законсьюмить сообщения дважды? Но группа kafkaapp-v0.1 уже не в ходу: нужно как-то "перекинуть" сообщения в kafkaapp-v0.2?
Мог ошибиться где-то с терминами. Если так, поправьте. Спасибо!
Оставить название консьюмер группы прежним можно? То есть не изменять его с версией приложения
Обсуждают сегодня