我可以从Python调用Bluemix消息中心服务吗？

Question

kafka-python客户机支持Kafka0.9，但显然不包括新的身份验证和加密功能，因此我猜测它只适用于开放式服务器（与以前的版本一样）。在任何情况下，甚至Java客户机都需要一个特殊的消息中心登录模块来连接（或者从示例中可以看出，除非有一个类似的模块可用于Python，否则什么都不能工作。在

我的具体场景是，我希望使用Jupyter笔记本的消息中心服务，该笔记本也托管在Bluemix（apachespark服务）中。在

Answer 1

我可以使用kafka python库进行连接：

$ pip install --user kafka-python

然后。。。在

^{pr2}$

这在bluemixspark作为jupyter笔记本的一项服务中起到了作用，但是请注意，这种方法并没有使用spark。代码只是在驱动程序主机上运行。在

Answer 2

在bluemixapachespark服务本机支持之前，您可以使用与Realtime Sentiment Analysis project相同的方法。可在cds labs spark samples github repo上找到此帮助程序代码。在

Answer 3

Kafka Python客户机中的SASL支持已被请求：https://github.com/dpkp/kafka-python/issues/533，但在messagehub使用的用户名/密码登录方法得到支持之前，它将无法工作