Как долго сохраняются в Кафке скрепленные журналы?

Question

Я новичок в Apache Kafka. Я читал о политике очистки Compaction. Меня это особенно интересует, потому что я хочу использовать эту политику по темам, которые используются для синхронизации разных хранилищ данных для достижения конечной согласованности.

Я вижу, что есть опция delete.retention.ms, доступная мне для использования. Но это относится только к «удалять» надгробные плиты/полезную нагрузку. Я понимаю, что этот параметр ограничивает время, в течение которого я могу повторно запустить пользователя после того, как не просмотрел записи от offset=0. Тем не менее, я никогда не удаляю ничего в своей системе. Другими словами, я никогда не собираюсь «удалять» надгробные плиты/полезную нагрузку.

Поскольку я никогда не собираюсь удалять надгробные плиты, я хочу знать, как долго Кафка будет хранить уплотненный журнал?

ПРИМЕЧАНИЕ: Я столкнулся с вопросом this, который привел меня к вопросу this. Это не отвечает на то, что мне нужно знать, или это не то, что я могу использовать, чтобы установить предел продолжительности жизни компактного журнала. Поправьте меня, если я ошибаюсь.

Answer 1

Если вы используете журнал уплотнению (и не войти сохранение) Кафка будет держать последнюю запись для каждого ключ навсегда (пока вы не удалите весь ключ с явным надгробием сообщением <key:null>).