如何传递一个变量来从python中的文本文件中读取多个ssl schema\u注册表url?

dpiehjr4  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(205)

无法从ssl avro producer的文本文件中读取多个url

AvroProducer{'schema_registry.url': filename}

https://github.com/confluentinc/confluent-kafka-python

7tofc5zh

7tofc5zh1#

python中的avroproducer/consumer不支持多个url。
https://github.com/confluentinc/confluent-kafka-python/issues/409
而财产本身需要是一串 host:port ,不是文件
解决方法是自己发出http请求,然后在地址列表上重试,然后得到一个有效的地址,或者花点时间在网络中部署负载均衡器

相关问题