usr/lib/python3.6/site-packages/kafka/client_async.py", line 826, in check_versionkafka.errors.NoBrokersAvailable: NoBrokersAvailable
从Consumer类中删除ssl参数的全部目的是验证SSL设置是否正常工作。
BOOTSTRAP_SERVERS = ['kafka:9092']
我发现了NoBrokersAvailablelocal/lib/python3.6/site-packages/kafka/client_async.py", line 819, in check_version
raise Errors.NoBrokersAvailabl
local/lib/python2.7/dist-packages/kafka/client_async.py", line 791, in check_version kafka.errors.NoBrokersAvailable: NoBrokersAvailable
我从messagehub服务凭据对象获得了kafka_brokers_sasl、sasl_plain_username
local/lib/python2.7/dist-packages/kafka/client_async.py", line 791, in check_versionkafka.errors.NoBrokersAvailable: NoBrokersAvailable
但是当我在主机上运行它们时,它们就完美地工作了。