如何检查 Kafka 主题保留期

Kafka是一个分布式流式数据平台，它使用主题（topic）来对数据进行分类和组织。主题保留期是指在Kafka中保留主题消息的时间。当消息的存储时间超过保留期限制后，Kafka将自动删除这些消息。

方法一：使用 Kafka命令行工具

Kafka提供了命令行工具kafka-topics.sh，可以使用它来检查主题保留期。

```shell
$ bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic topic_name

其中，`localhost:2181`是ZooKeeper的地址，`topic_name`是要检查的主题名称。执行以上命令，将会返回主题的描述信息，其中包含了保留期信息。

### 方法二：使用Kafka AdminClient API
Kafka还提供了AdminClient API，可以通过编写Java程序来检查主题保留期。

首先，需要创建一个`Properties`对象，设置Kafka的相关配置，例如Kafka集群的地址、端口等。

```markdown
```java
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "my-group");
props.put("key.deserializer", StringDeserializer.class.getName());
props.put("value.deserializer", StringDeserializer.class.getName());

AdminClient adminClient = AdminClient.create(props);

然后，使用`AdminClient`对象的`describeTopics`方法来获取主题的描述信息。

```markdown
```java
DescribeTopicsOptions options = new DescribeTopicsOptions().timeoutMs(5000);
KafkaFuture<Map<String, TopicDescription>> topicDescriptions = adminClient.describeTopics(Arrays.asList("topic_name"), options).all();

try {
    Map<String, TopicDescription> descriptionMap = topicDescriptions.get();
    for (Map.Entry<String, TopicDescription> entry : descriptionMap.entrySet()) {
        TopicDescription topicDescription = entry.getValue();
        TopicPartitionInfo partitionInfo = topicDescription.partitions().get(0);
        System.out.println("Topic: " + entry.getKey());
        System.out.println("Retention period: " + partitionInfo.topic());
    }
} catch (Exception e) {
    e.printStackTrace();
}

以上代码中，`topic_name`是要检查的主题名称，`Retention period`即为保留期。

注意：需要引入Kafka的相关依赖，例如`kafka-clients`。
```markdown
```xml
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>2.8.1</version>
</dependency>

以上是检查 Kafka 主题保留期的方法。你可以选择使用Kafka命令行工具或编写Java程序来实现。使用命令行工具更简单方便，而使用API可以更灵活地集成到你的应用程序中。