message-hub

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

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上執行這段代碼。有沒有人得到同樣的症狀？這是我發送的消息。