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

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();