Восстановление баланса kafka занимает много времени для удаления устаревшего государственного каталога - PullRequest
0 голосов
/ 11 октября 2018

Всякий раз, когда я пытаюсь вызвать потребителя для своей группы потребителей, Кафка тратит много времени на восстановление баланса и застревает в этом журнале.

Deleting obsolete state directory 0_45 for task 0_45 as 601021ms has elapsed (cleanup delay is 600000ms).

У меня есть 8 потоковых тем по теме, которую я хочуподписаться на и эта тема имеет 64 раздела.

Все как max.poll.records, session.timeout.ms все значения по умолчанию в кафке.Я пытался найти решение этой проблемы, но ничего не смог найти.

...