为kafka主题更改retention.ms属性删除旧数据

Question

我试图更改现有主题的retention.ms属性，但根据我的分析，它删除了主题中的所有现有数据。

场景：-最初我的主题名是"topic1"，保留时间为5分钟，它包含一些数据。

用例1-使用以下命令将保留时间更改为更高的时间段，然后将retention.ms值更改为8分钟：

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

但它删除了这个话题中我所有的旧数据。在那之后，我把更多的数据放到了这个话题上。

用例2-将保留时间更改为较低的时间段，然后使用以下命令将retention.ms值更改为3分钟：

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

它还删除该主题中以前的数据。

谁能告诉我同样的行为。

任何小费都要感谢！

Answer 1

卡夫卡的retention.ms属性需要几毫秒。因此，您正在将保留期分别更改为8毫秒和3毫秒。如果你想设置8分钟的保留期，你必须给480000。