Меняет ли Kafka смещение на 0 после очистки разделов?

Question

Предположим, что Кафка очищает наши разделы после 1000 событий. Я хочу установить смещение c с помощью функции поиска в Consumer. Нужно ли мне устанавливать начальное смещение на 1000 или 0 в методе поиска, если Kafka очищает раздел после 1000 сообщений?

Answer 1

Нет, смещение сообщения никогда не меняется. Это постоянный идентификатор позиции в журнале. Новое сообщение после очистки будет иметь смещение 1000.