apache-kafka – 我们如何使用Apache Kafka API获取主题的复制因子和保留时间

2019年7月27日 204次阅读

我们如何使用Apache Kafka API获取主题的复制因子和保留时间？

我使用的是0.9版本,并计算了如何使用AdminUtils来获取数量.

最佳答案 如果你已经熟悉了AdminUtils,那就没那么远了.获取您感兴趣的主题的配置.您将获得包含此主题的所有配置项的地图.至少在kafka 0.8.x中,保留配置的关键是“retention.ms”.所以让我们试试这个(免责声明 – 这是未经检查的代码)：

val zkUtils = ZkUtils(zkConnectionString,
                      30000,
                      30000,
                      JaasUtils.isZkSecurityEnabled())
val configs = AdminUtils.fetchEntityConfig(zkUtils, ConfigType.Topic, topicName)
val retention = configs("retention.ms")
点赞