问题标签 [message-hub]

kafka-python客户端支持 Kafka 0.9 ，但显然不包含新的身份验证和加密功能，所以我的猜测是它只适用于开放服务器（与以前的版本一样）。在任何情况下，即使是 Java 客户端也需要一个特殊的消息中心登录模块来连接（或者从示例中可以看出），这表明除非有可用于 Python 的类似模块，否则什么都不会起作用。

我的具体场景是，我想使用同样托管在 Bluemix 中的 Jupyter 笔记本中的消息中心服务（Apache Spark 服务）。

我安装了一个 Bluemix Message Hub 服务，然后添加了 Message Connector 以从 Twitter 获取流媒体。之后，我得到了一个 REST API url 来使用数据流。我使用带有相关标头和凭据的 firefox RESTClient 发布了 REST url，但得到了 40403 返回的错误代码。感谢您的建议。

最近使用 Message Hub 服务时，我发现以前工作的应用程序已经开始以KafkaException或失败Failed to update metadata。

我该如何解决？

我正在尝试使用 Grafana 监控 Bluemix Message Hub 上的消息，但图表“字节输入”和“字节输出”均未显示任何内容并显示“无数据点”。我能够查看的唯一图表是“randomWalk”……有没有办法查看消息数量、偏移量或显示 kafka 进出活动的内容？

FG

我有实现 Runnable 并在 bluemix 中实例化 kafka 消费者的 java 类。尝试实例化时，此类抛出异常KafkaConsumer。该jaas.conf文件存储在共享目录中。这在过去的 1 个月内运行良好。它今天开始抛出这个错误。我不记得对我的代码进行了任何更改。我正在使用 kafka-client 0.9.0.0。我还尝试使用 kafka 客户端 0.9.0.1 获得相同的结果。

文件 jaas.conf 位于它要查找的位置，并且其中包含以下内容。

我正在调用 IBM Bluemix Administration API for Message Hub（又名 Kafka），如此处所述。

调用端点https://kafka-admin-prod02.messagehub.services.eu-gb.bluemix.net:443/topics（使用与我们的 API 密钥相对应的适当X-Auth-Token值和 GET 动词）似乎有效 - 它返回我们在 Bluemix Message Hub 管理屏幕中手动配置的主题列表。

{name: 'mynewtopicname'}但是，使用动词 POST 和aContent-Type的主体调用相同的 URL application/json（根据 API 的 Swagger 文档，这似乎是正确的语法）不起作用 - 我得到“HTTP 405 Method Not”的结果允许”。无论我使用 GET、PUT、POST 还是 DELETE（这也意味着我无法删除主题），这似乎都会发生。

难道我做错了什么？

（如果相关，我在 UK Bluemix 实例上使用 Message Hub）。

当我尝试在 Message Connect 中创建消息流（来源：MQ Light）时，该流不会进入运行状态，而是出现错误。

我遵循的步骤：

1. 创建的消息中心：它工作正常，因为我使用 APache Kafka API 连接到它
2. 为我的本地 MQ 创建了安全网关：它也可以正常工作，因为我可以通过安全网关发布到我的本地 MQ
3. 创建消息连接
4. 创建的消息流：i。给定名称 ii。选择 MQ Light 作为我的事件源 iii。选定的安全网关 iv。以及对应的Destination v. 试图创建Stream，结果却是“Status: Error”

Bluemix 消息连接服务屏幕截图

我不知道在哪里可以看到日志，因为我是 Bluemix 的新手。所以请让我知道我错过了哪些步骤或如何调试它？

此外，当我尝试创建 Twitter 消息流时，它的行为也相同。意味着根本没有运行，进入错误状态而不显示任何错误。

我正在尝试使用 Kafka 输入节点 (node-red-contrib-kafka-node) 在 Bluemix 节点红色应用程序中使用消息。我有一个绑定到我的应用程序的消息集线器服务，并且我正在使用本地 Java 应用程序将消息写入主题。为了能够使用这些消息，Kafka 输入节点的 ZK Quorum 属性应该包含什么？

我成功地遵循了 DAVID TAIEB 的这个很棒的教程。问题是图表需要很长时间才能改变。它大约需要几分钟，而不是几秒钟，因为它应该是！

可能是什么问题呢 ？

当我在 Scala Notebook 中运行这个单元格时：

输出如下所示：

它看起来不像教程显示的那样： https://i0.wp.com/developer.ibm.com/clouddataservices/wp-content/uploads/sites/47/2016/01/Running-Spark-Streaming.png？缩放=2&w=980

我希望你能帮助我。是什么导致我的图表每隔几秒就改变一次？

当我关闭应用程序和内核并尝试重新打开它们时，这就是我所做的：

1-重新启动内核 2-再次运行所有单元

这是正确的吗 ？

谢谢@DavidTaieb

之前有人提出过我们是否可以使用 Python 访问 Message Hub 的问题。在用 Python 编写 SASL 实现之前，答案通常是否定的。

现在，有一个纯 Python SASL，叫做pure-sasl！，现在可以通过 Python 调用 Message Hub 了吗？

社区里有人有例子吗？