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

Question

我正在执行以下操作：

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

但我仍然收到诸如 xxx-kstreams-yyyy-changelog 或 xxx.internal.self.yyy

之类的主题名称

Answer 1

不，您无法通过设置 listInternal(false) 来避免那些主题名称。如前所述，它将排除 kafka _consumer_offsets 和 _transaction_state 主题。

如果您不想看到 kafka 流应用程序生成 changelog/repartition 个主题，您可以在您的代码中定义一个正则表达式，它可以排除所有匹配的主题并只给您用户主题。