retention ? Моя версия нет, но все же....
Проверял на https://github.com/streamthoughts/kafka-monitoring-stack-docker-compose судя по всему не включает. Делал ретеншн по размеру и по времени, генерил перфтестом и руками.
Спасибо. Просто мы тут поменяли ретеншен с очень короткого на нормальный и сразу же у нас стало РЕЗКО меньше читаться
В общем, я бы сначала исключил штатность поведения: убедился бы что есть лаг в консюмерах, что есть просадки в bytes-out от брокера. Если цепляются новые группы, то посмотреть на fetch.max.bytes и на то с каким оффсетом они цепляются - может у вас из-за ретешнов топик был совсем кроха и вычитывался мелкими батчами, а теперь пытаетесь проглотить слишком много за раз.
Обсуждают сегодня