apache-kafka - 如何检查Kafka中主题的保留期限?

标签 apache-kafka

我想知道如何获取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/

相关文章:

kubernetes - 没有自定义指标的水平Pod自动缩放

python - 两个永无休止的Python脚本之间的交互

java - 使用 Java API 定期获取 Kafka Producer 指标

java - Spring和卡夫卡: Join 3 Kafka topics to generate output Kafka streams

java - 无法反序列化压缩的 Protocol Buffer

spring-boot - spring kafka header 中没有类型信息,也没有提供默认类型

apache-kafka - Kafka主题创建最佳实践

apache-kafka - 谁在 Apache Kafka 中跟踪消费者的最后读取消息偏移量?

apache-kafka - 如何在 Kafka 0.10.1.0 中使用 Flink?

apache-kafka - Spark Streaming scala 性能极慢