1つのカフカトピックのメッセージを修正し、javaを使用して別のカフカトピックに送信する方法は？

Question

私は1つのトピックAにMSGを生成するプロデューサを作成しました。私はそのMSGの変更を行いたい、それを別のトピックに送信したいです。B、私はKafkaストリームでこれを行うようにしていますが、それは正しい方法であるかどうか。そのためにカフカのストリームが必要な場合は、書き込むコードを教えてください。

Answer 1

あなたはApache stormを使用して調べる必要がありますあなたのニーズに非常に適しています。

私はそれを使いました。それはとてもよく、カフカでミルクの水のようにジェルします。また、実装が非常に簡単です。

運が良ければ

Answer 2

これにはさまざまな方法があります。

KafkaのStreams APIは、プロジェクトに新しい依存関係を追加しないという利点があります。プログラムとして単純なstream.map(...).to(...)としてこれを行う必要があります。詳細は、ドキュメントと例をチェックアウト：

• http://docs.confluent.io/current/streams/index.html
• https://github.com/confluentinc/examples

は、あなたも、ちょうどより多くのように見える、これが行われ（ただし、カフカのストリームAPIを使用して、プレーンKafkaConsumerとKafkaProducerを取得するために使用することができますこれより自然）。

もちろん、Apache Flink、Apache Storm、Apache Apex、Heron（またはおそらくApache Spark）などのストリーム処理フレームワークを使用することもできます。プログラムは、上にスケッチしたように書くのと同様に簡単です。しかし、これらのストリーム処理フレームワークのためにジョブを展開するために、処理クラスターをセットアップする必要があります。