版本:合流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时陷入了困境,它将进入无限循环。。
我可以指定抛出某种异常需要多长时间吗?
暂无答案!
目前还没有任何答案,快来回答吧!