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

k5ifujac  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(915)

我正试图更改现有主题的retention.ms属性,但根据我的分析,它会删除该主题中的所有现有数据。
scenarios:- initially 我的主题名是 "topic1" 保留时间为5分钟,其中包含一些数据。
用例1-将retention更改为更高的时间段,然后使用下面的命令将retention.ms值更改为8分钟command:-

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

但它删除了我所有的旧数据。在那之后,我把更多的数据放进了这个主题。
用例2-将retention更改为较低的时间段,然后使用下面的命令将retention.ms值更改为3分钟command:-

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

它还会删除以前从该主题中删除的数据。
有人能告诉我同样的行为吗。
谢谢你的任何提示!

pod7payv

pod7payv1#

kafka中的retention.ms属性需要毫秒。所以您将保留期分别更改为8毫秒和3毫秒。如果你想设定8分钟的保留期,你得给48万。

相关问题