如何在可配置的时间线内获取 JSON 格式的活动/非活动主题答案

【问题标题】：How to get Active/Inactive Topics in JSON format within a configurable timeline如何在可配置的时间线内获取 JSON 格式的活动/非活动主题
【发布时间】：2020-09-20 12:16:33
【问题描述】：

有人可以解释或提供一些有用的链接以使用 Java 在 Kafka 中获取活动/非活动主题吗？

【问题讨论】：

嗨克里斯托，你说的不活跃是什么意思？你的意思是删除了吗？

标签： java spring-boot apache-kafka kafka-consumer-api kafka-producer-api

【解决方案1】：

如果我是对的，您正在寻找 Apache Kafka 提供的 AdminClient。这是其官方文档的Link。该 API 提供了多种方法 - 显示主题列表、创建/删除主题以及删除消费者组、创建分区等其他功能。

我正在编写我在项目中使用的示例代码，用于使用 AdminClient API 创建主题。

public static NewTopic createTopics(String topicName) throws IOException {
    Properties properties = new Properties();
    properties.load(new FileReader(new File("C:\\Users\\Dell\\Downloads\\kafka_2.12-2.3.0\\kafkaproperty\\kafka.properties")));
    AdminClient adminClient = AdminClient.create(properties);
    NewTopic newTopic = new NewTopic(topicName, 1, (short) 1); //new NewTopic(topicName, numPartitions, replicationFactor)

    List<NewTopic> newTopics = new ArrayList<NewTopic>();
    newTopics.add(newTopic);
    adminClient.createTopics(newTopics); // Creation of new topic
    adminClient.listTopics(); // List of topics which you can convert into JSON

    adminClient.close();
    return newTopic;
}

我希望这对您有所帮助。如果您有任何问题，请随时提问。

【讨论】：