我正试图更改现有主题的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
它还会删除以前从该主题中删除的数据。
有人能告诉我同样的行为吗。
谢谢你的任何提示!
1条答案
按热度按时间pod7payv1#
kafka中的retention.ms属性需要毫秒。所以您将保留期分别更改为8毫秒和3毫秒。如果你想设定8分钟的保留期,你得给48万。