当我尝试使用python的蓝色消息集线器时,我会继续收到错误和失败。有什么想法为什么给出以下?
错误是"无法初始化SASL身份验证:SASL握手不受经纪人的支持(机制平原要求)"
但是,当经营我的生产商和消费者时,它们似乎有效。产生消息并消耗消息。
我在输出中看到了与错误消息相混合的正确消息。
我已经安装了librdkafka,并根据说明确认了所有外观:
https://github.com/ibm-messaging/message-hub-samples/blob/master/docs/librdkafka.md
运行时,您可以在这里看到我的输出:
checking for libssl (by pkg-config)... failed
checking for libssl (by compile)... ok (cached)
checking for libsasl2 (by pkg-config)... failed
checking for libsasl2 (by compile)... ok (cached)
ENABLE_SSL y
ENABLE_SASL y
谢谢亚伦
您可能会看到该错误消息,因为您正在使用的librdkafka的最新版本。消息中心仍在运行KAFKA 10.0.0.1
请尝试将其添加到您的客户端配置
api.version.request=true
从python 3.5.x更新为python 3.6,错误就消失了。
此外,我将Anaconda更新为4.3.8。