В моей локальной системе работает брокер kafka.Чтобы общаться с неработающими с помощью моего веб-приложения на Django, я использую оболочку confluent-kafka .Однако, просматривая API администратора, я не смог найти API для перечисления тем Кафки.(Темы создаются прагматично и динамично).
Можно ли как-то перечислить их в моей программе?Требование состоит в том, что, если мой работник перезагружает всех назначенных потребителей, прослушивающих эти темы, потребуется повторная инициализация, поэтому я хочу выполнить цикл по всем темам и назначить потребителя каждой.