之前有人提出过我们是否可以使用 Python 访问 Message Hub 的问题。在用 Python 编写 SASL 实现之前,答案通常是否定的。
现在,有一个纯 Python SASL,叫做pure-sasl!,现在可以通过 Python 调用 Message Hub 了吗?
社区里有人有例子吗?
之前有人提出过我们是否可以使用 Python 访问 Message Hub 的问题。在用 Python 编写 SASL 实现之前,答案通常是否定的。
现在,有一个纯 Python SASL,叫做pure-sasl!,现在可以通过 Python 调用 Message Hub 了吗?
社区里有人有例子吗?
更新:
从那时起,我们发布了一个示例应用程序,演示如何使用 Python 访问 Message Hub:https ://github.com/ibm-messaging/message-hub-samples/tree/master/kafka-python-console-sample
是的,应该可以使用这个库连接到 Message Hub。
Message Hub 使用 SASL PLAIN 机制来执行身份验证。由于 Kafka 尚未正式支持此机制,因此目前还没有 Kafka 客户端实现它。但是,由于 Message Hub 使用标准 SASL PLAIN,因此可以根据需要编写一个。可以使用任何实现此机制的 SASL 库。
SASL PLAIN 需要用户名和密码。您可以从 VCAP_SERVICES 变量中获取这些值。
除了 Mickael 的回答之外,我们正在与 Kafka 社区合作,以获得 Kafka 基础支持的其他 SASL 方法。这是在 KIP 43 ( https://cwiki.apache.org/confluence/display/KAFKA/KIP-43%3A+Kafka+SASL+enhancements ) 下完成的。一旦这被 Kafka 的版本接受,我们将更新 Message Hub 以使用此社区支持的机制,但我们仍会在未来一段时间内支持现有机制。