如何使用Apache Kafka API獲取主題的複製因子和保留小時數

Question

如何使用Apache Kafka API獲取主題的複製因子和保留小時數？

我正在使用0.9版本，並想出如何使用AdminUtils來獲取paritiions的數量。

Answer 1

如果您已經熟悉了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")