我想知道如何获取Kafka主题的保留期限。 我们的 Kafka 集群的默认保留期是 7 天,即 log.retention.hours=168 但对于某些主题,它配置了自定义保留期,例如 3 天。
Kafka 版本是 0.10.0.1,我尝试了以下命令,但它没有提供保留期详细信息。
/bin/kafka-topics.sh -zookeeper localhost:2181 --describe --topic <topic-name>
displayed below output without retention details.
--------------------------------------------------
Topic:<topic-name> PartitionCount:50 ReplicationFactor:2 Configs:
Topic: <topic-name> Partition: 0 Leader: 7 Replicas: 7,22 Isr: 7,22
提前致谢!
最佳答案
如果您的保留期已更改,它将显示在配置中。从输出中,我可以看到您尚未设置 retention.ms
配置,因此将应用默认保留期。
如果您没有更改任何配置,则应该是 7 天(168 小时)。
下面是更改保留的示例输出。
Topic:<topic_name> PartitionCount:12 ReplicationFactor:3 Configs:retention.ms=18000000
关于apache-kafka - 如何检查Kafka中主题的保留期限?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58492461/