如何在可配置的时间轴中以JSON格式获取ActiveInactive主题。

Question

谁能解释一下或提供一些有用的链接来获取活跃的非活跃主题？卡夫卡 使用 爪哇?

Answer 1

如果我是对的，你要找的是 AdminClient 由Apache Kafka提供。这里是一个 鏈接 的官方文档。这个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;
}

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