message-hub

2热度

1回答

IBM消息中心 - 经过数小时的工作，很好，它通过代理不支持的SASL握手失败（机制PLAIN需要）

以下应用程序是一个简单的消费者，它将所有消息打印到控制台。 #!/usr/bin/env python import confluent_kafka consumer = confluent_kafka.Consumer({ 'bootstrap.servers': 'kafka05-prod01.messagehub.services.us-south.bluemix.net:90

0热度

1回答

OpenWhisk消息包 - messageHubProduce unstable

我试图使用“whisk.system/messaging”并尝试使用messageHubProduce方法。我创建了一个绑定到这个包，并尝试使用邮递员的简单调用。使用文档，我创建了一个简单的json并进行了调用，但该方法非常不稳定。同一个电话有时会成功返回，有时会返回超时，有时会以“没有经纪人可用”的形式返回。我现在在python上执行这段代码。有没有人得到同样的症状？这是我发送的消息。

0热度

1回答

Bluemix上的节点红色是否允许连接到MessageHub MQLight主题？

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

1热度

1回答

消费者卡在重新加入

我已阅读其他线程，并通过使用新的组ID识别问题，但是我想了解可能导致此问题的原因。我有一个主题与16个分区，我已经设置session.timeout.ms = 30000和max.poll.interval.ms = 30000000。我运行我的程序，并按ctrl + c它，所以它没有正确关闭。我猜，16次之后，我陷入了这个重新加入的问题。 session.timeout.ms是心跳超时，所以

3热度

1回答

用户界面控制台浏览Message Hub上的主题

我在Bluemix上有一个Message Hub实例，并且能够生成/使用消息。我一直在寻找一种快速，合理的方式来浏览主题/消息，看看发生了什么。沿着kafka-topics-ui的路线行事。我在本地安装了kafka-topics-ui，但无法连接到Message Hub。我使用kafka-topics-ui配置文件（env.js）中的MessageHub凭证中的kafka-rest-url值，但

1热度

1回答

无法从Bluemix Liberty连接到BlueMix MessageHub

我有一个连接Bluemix Message Hub的Liberty应用程序。它在本地运行良好，但是当我从Bluemix Liberty运行Liberty应用程序时，它无法工作。我正在关注https://github.com/ibm-messaging/message-hub-samples/tree/master/kafka-java-liberty-sample中的示例，您可以在运行时更改ser

0热度

1回答

卡夫卡错误的主题我没有订阅

我看到一个关于我的当前实例没有订阅的主题kafka警告。我们使用相同的卡夫卡经纪人，每个开发者都有他/她自己的主题。但是，我们都使用在属性文件中指定的相同默认组ID/clientid。 2017-06-27T11:48:35.20-0400 [APP/PROC/WEB/0]OUT 2017-06-27 15:48:35,195 WARN [NetworkClient] - [kafka-coord

0热度

1回答

IBM消息集线器与C＃汇合api的沟通

我一直在尝试通过C＃Apache Kafka Confluent API查找连接到IBM Message Hub的文档，但尚未成功。 github的官方回购没有C＃的样本。任何人都可以使用C＃与ibm消息中心进行通信，如果是，您是否可以共享该流程？谢谢。更新：我已经成功地与IBM Message Hub进行通信。库： librdkafka -... 0.11.0-RC2 证书来源：http

0热度

1回答

连接到IBM Message Hub的kafka输入插件发生不可恢复的错误

我试图从logstash使用IBM Message Hub。我logstash.conf： input { kafka { bootstrap_servers => "kafka04-prod01.messagehub.services.eu-de.bluemix.net:9093,kafka05-prod01.messagehub.services.eu-de.bluemi

0热度

2回答

使用C＃和Confluent连接到IBM消息中心

我试图使用IBM消息中心创建生产者和消费者应用程序。对于生产者我使用以下代码： var config = new Dictionary<string, object> { { "bootstrap.servers", brokerList }, { "group.id", "simple-csharp-producer" }, { "client.i