Kafkaメッセージにワークフローを追加する方法は？

Question

JavaプロジェクトをRabbit MQからKafkaに移行しています（何らかの理由で）。

しかし、私は1つの困難に直面しています。

現在のワークフローでは、すべてのメッセージをrabbit mq exchangeに送信し、メッセージのルーティングキーに基づいてメッセージを1つ以上のキューにリダイレクトします。 私はカフカでも同じ機能を保持したいと思います。 （私はカフカはもともとそれに適していないが、私は回避策が欲しい）。

基本的には、次のようなものが必要です。トピック内でメッセージが受信されるたびに、メッセージが他のトピックセットにリダイレクトされる必要があります。

これを達成する最も速い方法は何ですか？あなたは、彼らがすべて同様のキーが同じパーティションに行くような話題パーティションに送られますキーでカフカのメッセージを公開する場合、私はPythonやJavaソリューション

おかげ

Answer 1

を好むだろう。

また、Kafkaストリームを使用して入力トピックを読み取り、メッセージに付属するキーに基づいて一連の出力トピックにメッセージをルーティングすることができます。