Kafka Admin:如何以编程方式显示和设置每个主题的保留时间？

Kafka Admin 是 Kafka 提供的一个管理工具，用于以编程方式管理 Kafka 集群。要以编程方式显示和设置每个主题的保留时间，可以使用 Kafka Admin 的 API 进行操作。

首先，通过 Kafka Admin API 获取到 KafkaAdminClient 对象，然后通过该对象获取到 AdminClient 对象，用于进行管理操作。具体代码如下：

Properties props = new Properties();
props.put("bootstrap.servers", "kafka-broker1:9092,kafka-broker2:9092"); // Kafka 集群的地址

AdminClient adminClient = AdminClient.create(props);

ListTopicsResult listTopicsResult = adminClient.listTopics();

// 显示每个主题的保留时间
Map<String, TopicDescription> topics = listTopicsResult.namesToListings().get();
for (Map.Entry<String, TopicDescription> entry : topics.entrySet()) {
    String topicName = entry.getKey();
    TopicDescription topicDescription = entry.getValue();
    System.out.println("Topic: " + topicName);
    System.out.println("Retention Time: " + topicDescription.retentionMs());
}

// 设置指定主题的保留时间
ConfigEntry retentionTimeConfig = new ConfigEntry(TopicConfig.RETENTION_MS_CONFIG, "86400000"); // 保留时间为 1 天
Config topicConfig = new Config(Collections.singleton(retentionTimeConfig));
AlterConfigsResult alterConfigsResult = adminClient.alterConfigs(Collections.singletonMap(new TopicPartition(topicName, 0), topicConfig));
alterConfigsResult.all().get();

adminClient.close();

上述代码中，首先创建了一个 KafkaAdminClient 对象，使用 Kafka 集群的地址进行配置。然后通过 AdminClient.listTopics() 方法获取到主题列表，并遍历每个主题，显示其保留时间。接着，创建一个 ConfigEntry 对象，设置保留时间的配置项，然后创建一个 Config 对象，将该配置项添加到其中。最后，通过 AdminClient.alterConfigs() 方法将新的配置应用到指定主题上。

需要注意的是，上述代码中的 Kafka 集群地址需要根据实际情况进行修改。

推荐的腾讯云相关产品：腾讯云消息队列 CKafka（https://cloud.tencent.com/product/ckafka），CKafka 是腾讯云提供的高吞吐、低延迟的消息队列产品，完全兼容 Kafka 协议。可以通过 CKafka 控制台或者 CKafka SDK 进行主题的保留时间设置和管理。