Время хранения старых сообщений в теме Кафки после изменения конфигурации

Question

Я запихнул несколько сообщений в кафку-тему.Я изменил время хранения после этого на гораздо более длительное время с помощью:

kafka-topics --zookeeper localhost:2181 --alter --topic $topic--config retention.ms=120960000000

Будет ли это применяться только к новым сообщениям, отправленным или к более старым сообщениям, уже существовавшим в теме ранее?

Заранее спасибо!

Answer 1

retention.ms - это конфигурация на уровне темы, которая влияет на данные, которые в данный момент присутствуют в вашей теме.Неважно, были ли данные добавлены в тему до или после изменения этой конфигурации.