Владислав Тарбаев

Можно вопрос, вы про какой плагин говорите?

А если час?

можно скриптом считать все оффсеты по партициям старого group.id и проставить их для нового?

А если сделать количество консьюмеров равным количеству партиций?

что значит занята?

то что лаг растет при выключении консьюмера это нормально. кстати лаг растет для группы в которой консьюмер находится?

'enable.auto.commit' => 'false', - в коде коммит делать придется?

я правильно понимаю что reassign это перенос сообщений из партиций на новую ноду?

offset двигается после вычитки?

как это конкретный оффсет для всех партиций?

там можно, то вопрос наверное как это сделать в коде?

размер лага до какого значения вырастает?

консьюмер не отваливается случаем?

ты про акнолидж?

Чем читаешь?

А Консьюмеров?