Я использую confluent Kafka Go для моего проекта.При написании тестов из-за асинхронного характера Kafka при создании темы у меня могут возникнуть ошибки (код ошибки 3: UNKNOWN_TOPIC_OR_PARTITION) при создании темы и немедленном возвращении.
Как я понял, если я могу делать запросы непосредственно на контроллере, я всегда могу получить самые последние метаданные.Поэтому мой вопрос: как я могу получить IP-адрес или идентификатор контроллера Kafka при использовании Confluent Kafka Go.