message-hub

    0熱度

    2回答

    我安裝了Bluemix Message Hub服務,然後添加Message Connector從Twitter獲取流式傳輸。之後,我得到了一個REST API網址來使用數據流。我使用firefox RESTClient發佈了REST url,並帶有關聯的頭文件和憑證,但得到了40403返回的錯誤代碼。 感謝您的建議。

    20熱度

    5回答

    使用Apache Kafka Java客戶端(0.9),我試圖使用Kafka Producer class向經紀人發送一長串記錄。 異步send method會立即返回一段時間,然後在短時間內開始阻止每個呼叫。大約三十秒後,客戶端開始拋出異常(TimeoutException),消息「批量過期」。 什麼情況會導致此異常被拋出?

    1熱度

    1回答

    最近使用Message Hub服務時,我發現之前正在運行的應用程序已開始以KafkaException或Failed to update metadata失敗。 我該如何解決這個問題?

    2熱度

    2回答

    我知道還沒有這個功能,但是,它將來會提供嗎?

    2熱度

    1回答

    bluemix.net上的「消息中心入門(BETA)」頁面指出,對於Java生產者「...消息必須採用以下格式:[{」value「 :string},...]「。 我在Kafka文檔中找不到任何對此格式的引用,當發送的文本不是這種格式時,服務工作得很好,當我嘗試使用它時,消費者沒有將多個「值」字符串分開 - 多個值剛剛作爲單個JSON消息到達。 那麼,有沒有人對這個聲明的要求的起源,需要或潛在利益

    1熱度

    2回答

    我試圖監視使用Grafana的Bluemix Messsage Hub上的消息,但這兩個圖都是'Bytes In'和'Bytes out'不顯示任何內容並且顯示'沒有數據點'。 我可以查看的唯一圖形是'randomWalk'.... 有沒有辦法查看消息的數量,偏移量或顯示kafka活動的內外進程? F.G.

    1熱度

    4回答

    kafka-python客戶端支持Kafka 0.9,但顯然不包含新的身份驗證和加密功能,所以我的猜測是它只適用於開放服務器(如以前的版本)。無論如何,即使Java客戶端需要一個特殊的消息中心登錄模塊來連接(或者從示例中看來),這表明除非有類似的Python模塊可用,否則什麼都不會起作用。 我的具體情況是,我想使用也在Bluemix(Apache Spark服務)中託管的Jupyter筆記本中的消

    1熱度

    1回答

    當我嘗試在Message Connect中創建消息流(源:MQ Light)時,流不會進入運行狀態,而是出現錯誤。 的步驟我跟着: 創建的消息中心:其工作罰款,我連接到該使用Apache卡夫卡API 創建的安全網關,以我的本地MQ:它也工作正常,因爲我能通過安全網關發佈到我的本地MQ 創建消息連接 創建消息流: i。給定名稱 ii。選定的MQ Light作爲我的事件來源 iii。選定的安全網關 i

    2熱度

    1回答

    當我運行從https://github.com/ibm-messaging/message-hub-samples我得到下面的異常卡夫卡機消息中心的示例代碼: Exception in thread "main" org.apache.kafka.common.KafkaException: Failed to construct kafka producer at org.apache