Alter свойство retention.ms для темы kafka удаляет старые данные

Question

Я пытаюсь изменить свойство retention.ms для существующей темы, но, согласно моему анализу, он удаляет все существующие данные внутри темы.

Сценарии: - Первоначально мое название темы: "topic1" с удержанием 5 минут и содержит некоторые данные.

Use Case 1 - Изменение удержания на более высокий период Тогда я изменить значение retention.ms до 8 минут с помощью следующей команды: -

bin/kafka-topics.sh --alter --zookeeper localhost:2181 
    --topic topic1 --config retention.ms=8 

Но он удаляет все мои старые данные, что тема. После этого я нажал еще несколько данных в эту тему.

Use Case 2 - Изменение удержания на более низкий период Тогда я изменить значение retention.ms до 3 минут с помощью следующей команды: -

bin/kafka-topics.sh --alter --zookeeper localhost:2181 
    --topic topic1 --config retention.ms=3 

Он также удаляет предыдущие данные, которые от тема.

Может кто-нибудь, пожалуйста, сообщите мне точное поведение для того же самого.

Любые советы оценены!

Answer 1

retention.ms Недвижимость в Кафке занимает миллисекунды. Таким образом, вы меняете период хранения на 8 и 3 миллисекунды соответственно. Вы должны дать 480000, если вы хотите установить период удерживания 8 минут.