диска, в лог пишет много сообщений вида
[2021-11-09 21:23:23,699+0300] INFO kafka.log.Log: [Log partition=, dir=] Found deletable segments with base offsets [581833759] due to log start offset 582522627 breach
[2021-11-09 21:23:23,699+0300] INFO kafka.log.Log: [Log partition=, dir=] Scheduling log segment [baseOffset 581833759, size 536865779] for deletion.
[2021-11-09 21:23:24,167+0300] INFO kafka.log.Log: [Log partition=, dir=] Deleting segment 544438868
[2021-11-09 21:23:24,167+0300] INFO kafka.log.LogSegment: Deleted log /00000000000544438868.log.deleted.
[2021-11-09 21:23:24,167+0300] INFO kafka.log.LogSegment: Deleted offset index /00000000000544438868.index.deleted.
[2021-11-09 21:23:24,168+0300] INFO kafka.log.LogSegment: Deleted time index /00000000000544438868.timeindex.deleted.
но сообщения не принимает и вообще не выглядит живым?
возможно применился параметр, например, delete.retention.ms, который изменили до перезапуска брокера, до минимальных значений....
возможно у тебя закрылись сегменты и началось удаление
Если остановили кафку неправильно то после рестарта она может долго подниматься
Java?
Обсуждают сегодня