Confluent Kafka AdminClient зайдет в бесконечный цикл, если предоставлена ​​неправильная конфигурация

Версия: confluent-kafka==1.3.0

Ссылка: https://docs.confluent.io/current/clients/confluent-kafka-python/

Я заметил странное поведение при создании объекта AdminClient в python и заметил, что он будет работать в бесконечном цикле, когда указана неправильная конфигурация, поэтому я ожидал, что он выдаст какое-то исключение, например TimeOutException, но не будет, он войдет в цикл..

Код для клиента администратора...

client = AdminClient(getKafkaConfiguration())

getKafkaConfiguration() вернет conf. здесь я даю неправильное значение bootstrap.servers. и программа застряла при создании администратора, и она зайдет в бесконечный цикл..

есть ли какой-либо вариант, где я могу указать, сколько времени нужно, чтобы вызвать какое-то исключение?

0 ответов

Другие вопросы по тегам