时间戳

首页 > 解决方案 > Kafka AdminClient listTopics：有没有办法忽略 kstreams 主题？

apache-kafka - Kafka AdminClient listTopics：有没有办法忽略 kstreams 主题？

问题描述

我正在执行以下操作：

    var listTopicOptions = ListTopicsOptions().listInternal(false)
    var topicsInKafka = adminClient().listTopics(listTopicOptions).names().get()

但我仍然得到像 xxx-kstreams-yyyy-changelog 或 xxx.internal.self.yyy 这样的主题名称

标签： apache-kafkaapache-kafka-streams

解决方案

不，您不能通过设置来避免这些主题名称listInternal(false)。如前所述，它将排除 kafka_consumer_offsets和_transaction_state主题。

如果您不想看到 kafka 流应用程序生成的更改日志/重新分区主题，您可以在代码中定义一个正则表达式，它可以排除所有匹配的主题并只为您提供用户主题。

推荐阅读