, когда количество сообщений достигает максимального значения retention.bytes, kafka удалит сообщения, смещение будет сброшено до нуля?

Question

Я новичок в kafka, когда мы используем kafka, мы можем установить retention.bytes. скажем, мы установили 1GB, если количество сообщений достигнет 1 ГБ, kafka удалит сообщения. Я хочу спросить, что смещение будет сброшено до нуля? второй, потребительский набор auto.offset.reset к самому большому, после того как kafka удалит сообщения, какое смещение начнется у потребителя?

Answer 1

Для вашего вопроса № 1, с соблюдением политики на основе размера и времени, журнал может быть перенесен в новый пустой сегмент журнала. Начальным смещением начального файла журнала будет смещение следующего сообщения, которое будет добавлено к журналу.

Для вашего вопроса # 2, это зависит. Если смещение, отслеживаемое потребителем, выходит за пределы диапазона из-за удаления сообщения, тогда оно будет сброшено до самого большого смещения.