2016-09-14 5 views
1

IBM Message Busの最新バージョンでは、カフカストリーム (http://www.confluent.io/blog/introducing-kafka-streams-stream-processing-made-simple/)がサポートされていますか。どのようにこれを行うにはどのサンプル/サンプル? 2 - はい、これは私が(BETAサービスをコネクタサービスがbluemixに存在する)カフカストリームにソースデータベース(Cloudant)から 1.ストリームデータをやろうとしています何のNode.jsBluemix Kafkaストリーム

で行うことができます。 Kafka Streamsを使用した集計データ(サマリー、カウントなど) 3. Webダッシュボードapp -frontend(Node.JS、D3.JS)はストリームを消費し、ダッシュボードをリアルタイムで更新します。

はあなたに感謝

+0

あなたはIBM MessageHubを意味していますカフカストリームをサポートしていますか? –

+0

こんにちはハンス、そうです。 IBM Message Hub(bluemix) –

答えて

6

あなたは間違いなく公開とのNode.jsを使っカフカ(別名IBM MessageHub)に加入して、ダッシュボードのすべての種類のカフカデータを視覚化することができます。最近、私はNode-Redとノード赤いダッシュボードとノード赤のcontrib-web-worldmapの両方を使って、良い結果を得ています。

nodejsのPub/subは、Confluent REST Proxy(IBM MessageHubが使用)またはlibrdkafkaの上に書いたようなネイティブなnode.jsクライアント(https://github.com/blizzard/node-rdkafkaを参照)を介して実行できます。 Confluentはいくつかのnodejsラッパー関数を書いて、RESTプロキシを使いやすくしました(https://github.com/confluentinc/kafka-rest-nodeを参照)

現在サポートされている主な言語は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/

+0

ハンスに感謝します。私はバージョンをチェックし、Bluemixはストリームアプリ機能を持つKafka v0,10をサポートしているようだ。私が使用して試すことができるJavaで書かれた良い例がありますか? Cloudantに接続するKafkaコネクタのベータサービスはバグのように見える –

+0

JavaでのKafka Streamの例がいくつかあります。https://github.com/confluentinc/examples –

+0

このページの例では、コンフルエントと動物園をインストールするように求められています。これはブルーミックスでどのように動作するのでしょうか? bluemixはすでにカフカクラスターを提供しています。コンフルエントで飼い主サービスは利用できません。 –

関連する問題