встречал? Не можем разобраться, помогает сброс оффсета и перезапуск консьюмера, но бывает, что эту операцию нужно повторить несколько раз до "выздоровления". Перед перезапуском стопаем все консьюмеры группы, где сбрасываем оффсет.
Добрый день. Мне помогло увеличение количество партиций кафки до 10 плюс по кронджобе выполняю ./bin/kafka-consumer-groups.sh --bootstrap-server <kafka-service>:9092 --all-groups --all-topics --reset-offsets --to-latest --execute Возможно, это не круто с точки зрения экспертов по кафке и сентри, но теперь хоть какая-то стабильность
а консьюмеры в ошибку не падают или тоже синхронно с ресетом оффсетов перезапускаются?
Вроде нет. Или быстро подхватываются. Он же делает ресет только тех топиков, у кого проблемы с офсетом
Количество консьюмеров увеличили?
Нет, больше ничего не трогал
Тогда смысла не много, можно было просто ретеншн поднять. Результат тот же был бы
Спасибо за совет, попробую, когда новые нестабильности начнутся. Единственное, что потребуются дополнительные ресурсы. Сейчас даже трогать страшно, смотрю на плавные графики даже без дропов с замиранием сердца 😄
Обсуждают сегодня