python - 如何通过变量从 python 中的文本文件中读取多个 SSL Schema_registry url？

Question

无法从 SSL Avro Producer 的文本文件中读取多个 url

AvroProducer{'schema_registry.url': filename}

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

标签： pythonapache-kafkaconfluent-platform

Answer 1

Python 中的 AvroProducer / Consumer 不支持多个 url。

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

并且属性本身需要是一个字符串host:port，而不是一个文件

解决方法是自己发出 http 请求，然后重试地址列表，然后获取有效的地址，或者花点时间在网络中部署负载均衡器