问题标签 [message-hub]

我正在尝试使用 IBM 消息中心创建生产者和消费者应用程序。对于生产者，我使用以下代码：

对于消费者，我正在使用类似的配置属性。

消费者的其余代码：

对于生产者：

无论如何，它没有用，没有任何迹象表明发送任何东西......缺少什么？或者我可以用它来工作吗？

我得到的日志：

*sasl_ssl://kafka03-prod02.messagehub.services.eu-gb.bluemix.net:9093/bootstrap：无法初始化 SASL 身份验证：平台不支持 SASL 机制“PLAIN”

* 1/1 经纪人倒闭

突然在 ibm 消息集线器上出现错误。“无法获取主题数据”。直到几个小时前，一切都运行良好。

已检查： 1. 用法。一切似乎都很好。

我正在尝试使用“whisk.system/messaging”并尝试使用方法 messageHubProduce。

我创建了一个绑定到这个包，并尝试使用邮递员的简单调用。使用文档，我创建了一个简单的json并进行了调用，但是该方法确实不稳定。相同的调用有时会返回成功，有时会返回超时，有时会返回“没有可用的代理”。我现在这段代码的实现是在 python 上的。有没有人和我一样的症状？

这是我要发送的信息。

{ "topic": "mytopic", "value": "MyMessage", "blocking": false } 这些是同一个调用的结果

messageHubProduce 4213b6a495bc4c5aa7af9e299ddd8fcd { "success": true }

我有一个问题，我的提交失败，因为 poll() 太长（为什么会发生这种情况，我不知道，没有消息，它只是在一个空队列上读取/提交，我的 poll-interval 设置为小时）。然后当它再次点击 read() 时，由于某种原因它不会重新平衡。然而，这只发生在我的代码在 bluemix 上运行时，当我在本地重现异常时，下一个 read() 会导致重新平衡。

从 CommitFailedException 中恢复的正确方法是什么？我应该 close() 并重新创建我的消费者吗？还是调用 read() 应该重新平衡并让我继续？

我在Bluemix 中创建了一个MessageHub 服务并绑定了一个Node Red 应用程序，也在Bluemix 中。在 MH 中，我添加了一个 MQLight 主题。当我尝试连接 Node Red 中提供的 mqlight 节点时，它显示 MQ Light 服务不可用。mqlight 节点是否有能力连接到带有 MQLight 主题的 MessageHub 服务？

我在 Bluemix 上有一个 Message Hub 实例，并且能够从中生成/使用消息。我一直在寻找一种快速、合理的方式来浏览主题/消息以查看发生了什么。类似于 kafka-topics-ui的东西。

我kafka-topics-ui在本地安装，但无法连接到 Message Hub。我在配置文件 (env.js) 中使用kafka-rest-url了 MessageHub 凭据中的值kafka-topics-ui，但无法确定在哪里提供 API 密钥。

或者，在 Bluemix UI 的 Kibana 下，我可以看到用于创建主题的日志条目。不幸的是，我看不到主题中消息的日志条目（也许我找错了地方或过滤器有误？）。

我的猜测是我缺少一些基本的东西。有没有办法：

• 配置一个工具，例如kafka-topics-ui连接到 MessageHub，或者，
• 轻松浏览主题消息？

干杯。

我有一个使用 node-rdkafka 1.0.3 的 Bluemix Node.js (6.1.0) 应用程序。它似乎工作正常，但有大量错误事件，例如Error: Local: Broker Transport Failureor Error: Local: Authentication failure。我设置的生产者选项是：

消费者有类似的设置加上group.id标签。

我想知道我是否应该担心这些错误以及是否有办法消除它们。谢谢！

以下应用程序是一个简单的消费者，它将所有消息打印到控制台。

一开始它工作得很好。几个小时后，我看到以下错误消息。一旦我重新启动脚本，它就会再次正常工作。

^C%3|1504028772.615|失败|consumer01#consumer-1| [thrd:sasl_ssl://kafka08-prod01.messagehub.services.us-south.bluemix.]：sasl_ssl://kafka08-prod01.messagehub.services.us-south.bluemix.net:9093/7：初始化失败SASL 身份验证：代理不支持 SASL 握手（机制 PLAIN 要求）%3|1504028772.615|ERROR|consumer01#consumer-1| [thrd:sasl_ssl://kafka08-prod01.messagehub.services.us-south.bluemix.]：sasl_ssl://kafka08-prod01.messagehub.services.us-south.bluemix.net:9093/7：初始化失败SASL 身份验证：代理不支持 SASL 握手（机制 PLAIN 要求）

这并不是一个真正的编程问题——而是一个关于不同实现选项的问题。

我正在尝试使用 DataStage 中的 Kafka 连接器将数据流式传输到 Bluemix 上的消息中心。连接器阶段只让我选择 Kerberos 进行身份验证。问题是，我目前没有 Kerberos 服务器，我认为我不能在 Bluemix 中设置一个，而 Bluemix / Message Hub 肯定需要某种形式的身份验证，所以我不能只在 DataStage 中设置身份验证为“否”（除其他原因外）。

在这一点上，我的问题基本上是：

1.) 是否甚至可以通过 Kerberos 服务器授权某人使用 Bluemix 上的 Message Hub 服务，而不是在 Bluemix 上？

2.) 考虑到任何一种都是可能的，基于 Bluemix 的 Kerberos 服务器或“外部”服务器：据我了解，Kerberos 只能授予对服务器上某些服务的访问权限。我是否正确地假设 Bluemix Message Hub 凭证将成为对客户端的 TGS（票证授予服务器）回复的一部分？

3.) 万一，Kerberos 方法根本不起作用：在我们的 DataStage 服务器上配置消费者、生产者和 jaas 配置文件是否有意义，类似于： https: //www.youtube.com/watch？ v=tt-bLtFzC_4（大约 1:40 标记）将静态连接作为中间解决方案？（你可能会问：“他为什么不自己尝试？” - 好吧，不幸的是，我不是服务器管理员......）

4.) 如果这两个想法都是胡说八道，你会如何解决这个问题？

还有一件事：不幸的是，目前还不能选择使用 REST API（但希望很快就会成为一种选择……）。

我正在尝试使用 Kafka Streams 0.10.2.1 运行从一个主题到另一个主题的基本管道

如果我查看目标主题，我可以看到那里产生了记录。生成记录大约 1 分钟，然后该过程失败并出现以下错误：

更多信息：

• 我正在运行一个流应用程序实例（在我的笔记本电脑上）
• 我每秒将大约 400 条记录写入源主题。
• 源主题有 20 个分区
• 目标主题有 20 个分区

该错误表明问题出在目标主题上？进一步调试的下一步是什么？