问题标签 [message-hub]

我正在使用 python cloud Foundry 客户端创建一个 Message Hub 服务实例：

该服务已创建，但是当我使用管理控制台查看凭据时，它们是空的：

我在 python 客户端的集成测试代码中看到可以创建参数和标签：

因此，我猜我需要传递一些额外的东西来告诉 bluemix 为我创建一些默认凭据？

Bluemix MessageHub 文档将 python 用户指向 confluent kafka 库：

所以我尝试安装：

但是，我遇到了这个错误：

我正在尝试连接到 IBM Bluemix 消息集线器并按照示例使用 java 生成一条消息

https://github.com/ibm-messaging/message-hub-samples/tree/master/java/message-hub-kafka-ssl

生产者属性

jaas.conf.template

Producer.java 片段

问题是，当我尝试获取 Future RecordMetadata 时出现超时异常

阅读关于同一主题的早期帖子

超时连接到 Bluemix 上的消息集线器

提到的可能原因是未创建主题。我可以在 bluemix 控制台中看到主题并进行验证，我在推送消息之前调用了其余服务以获取主题列表

它返回我试图推送消息但我收到超时错误的主题。

有人可以帮我调试问题吗

更新

根据评论，我为 kafka 启用了调试日志，这是日志的顺序

以上所有内容均针对 5 个经纪人中的任何一个进行记录。这些都是调试语句，所以我不确定它们是否是错误的。

-塔塔

如果我在一个空间 MY_ANALYTICS_SPACE 中有 MessageHub 服务，并且在另一个空间MY_WEBAPPS_SPACE中有应用程序。这些空间代表了组织的两个不同部分，并被设计为保持独立。

但是，像 MessageHub 这样的企业级集成技术可能会跨越多个空间。

当服务和应用程序位于不同的空间时，是否可以将 MessageHub 的连接详细信息注入到我的应用程序的 VCAP_SERVICES中？

经常在使用 MessageHub 进行开发时，我发现我想从一个主题中清除我的开发数据。

如何清除 MessageHub 主题？

这个问题类似于Purge Kafka Queue但有所不同，因为这个问题是针对 apache kafka 的，我不确定 Message Hub 是否支持 kafka 命令行工具。

我使用 node.js 创建了一个主题，并使用原型 MessageHub.prototype.topics.create(topic) 映射到 Message Hub。我想将现有的 Message Hub 主题添加到 node.js 并从中使用数据。这有什么功能吗？

我是 LoopBack 连接器开发的新手。谁能帮助我了解什么是入站支持、出站支持和什么是轮询 API。

我正在尝试使用 kafka rest API 访问消息中心实例。当我通过邮递员客户端发送发布请求并给出Content-Type以下application/vnd.kafka.json.v1+json响应时

有人可以帮我吗？我也在X-Auth-TokenHeader 中传递 api 密钥。

尝试将 Message Hub Bluemix 服务与 confluent-kafka-python 一起使用时，我收到 ERROR Uncaught exception: , KafkaError{code=_INVALID_ARG,val=-186,str="No such configuration property: "sasl.mechanisms"" }

我收到 ERROR Failed to initialize SASL authentication: SASL handshake failed (start (-4)): SASL(-4): no mechanism available: No worthy mechs found when trying to use Message Hub Bluemix service with node-rdkafka

为什么会发生这种情况？