get_topics

connect_manager.utils.get_topics(broker_url, filter_regex, blacklist)

Get existing topics in Kafka.

Parameters:
broker_url : str

Kafka broker URL.