Bluemix Kafka streams

最新版本的IBM Message Bus是否支持Kafka Streams （此處描述的是...... http://www.confluent.io/blog/introducing-kafka-streams-stream-processing-made-simple/）。有關如何做到這一點的任何示例/示例？ 2 - 如果是的話，是否可以用Node.js的Bluemix Kafka streams

我所試圖做的從源數據庫（Cloudant） 1.流數據卡夫卡流（BETA服務存在於bluemix連接服務）來完成。使用Kafka流的聚合數據（摘要，計數等） 3. Web儀表板應用程序-frontend（Node.JS，D3.JS）實時使用流並更新儀表板。

謝謝

來源

2016-09-14 Narayana Ishwar

你的意思是IBM MessageHub？ –

嗨漢斯，是的。 IBM Message Hub（在bluemix中） –

你絕對可以發佈和如何使用Node.js訂閱卡夫卡（又名IBM MessageHub），你可以在各種儀表盤的可視化數據卡夫卡。最近我一直在使用Node-Red，並且使用node-red-dashboard和node-red-contrib-web-worldmap，結果很好。

來自nodejs應用程序的發佈/訂閱可以通過Confluent REST代理（IBM MessageHub使用）或通過本地node.js客戶端完成，就像暴雪在librdkafka頂部寫的一樣（請參閱https://github.com/blizzard/node-rdkafka）。 Confluent編寫了一些nodejs包裝函數，以使它更易於使用REST代理（請參見https://github.com/confluentinc/kafka-rest-node）

就Kafka Streams而言，今天支持的主要語言是Java和Scala。您可以將Javascript中的節點客戶端與Java中的Streams應用程序混合使用，而不會出現問題Kafka Streams僅作爲Java庫實現，因此您的流應用程序肯定會在虛擬機或容器中的Bluemix中運行，並且不需要任何其他集羣管理器或第三方基礎架構。

UPDATE：IBM宣佈MessageHub現在支持卡夫卡流

https://developer.ibm.com/messaging/2017/06/28/messagehub-now-runs-kafka-0-10-2-1-supports-streams/

來源

2016-09-15 06:39:00

謝謝Hans。我檢查了這個版本，看起來像Bluemix支持Kafka v0,10，它具有流應用程序的功能。是否有任何用Java編寫的好例子，我可以使用和嘗試。連接到Cloudant的Kafka連接器測試版服務看起來像buggy –

Java中的一些Kafka Streams示例在這裏https://github.com/confluentinc/examples –

頁面上的示例要求安裝confluent和zookeeper。不知道如何在bluemix中運行。 bluemix已經提供了kafka集羣，confluent和zookeeper服務不可用。 –

Bluemix Kafka streams

回答

相關問題