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 stream темы разделов изменений / перераспределения, вы можете определить в своем коде регулярное выражение, которое можетисключить все подходящие темы и дать вам только пользовательские темы.