合流kafka adminclient将进入无限循环,其中提供了错误的配置

biswetbf  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(200)

版本:合流Kafka==1.3.0
裁判:https://docs.confluent.io/current/clients/confluent-kafka-python/#pythonclient-管理员客户端
在python中创建adminclient对象时,我注意到了一个奇怪的行为,并且注意到当提供了错误的配置时,它将进入无限循环,所以我希望它抛出一些异常,比如timeoutexception,但它不会,它将进入循环。。
管理客户端的代码。。。

client = AdminClient(getKafkaConfiguration())

getkafkaconfiguration()将返回conf。在这里,我给出了错误的bootstrap.servers值。程序在创建admin时陷入了困境,它将进入无限循环。。
我可以指定抛出某种异常需要多长时间吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题