ストームを使用してメッセージを再生した後、カフカで注文を続ける

Question

私はストームスパウトとしてApache Kafkaを使用します。 私はカフカからのメッセージを受け取り、これらのメッセージを処理し、それらをカフカに送り返します。

私は同じ順序でメッセージを保存できるのだろうかと思います。すなわち

topic01：A、B、C - >嵐 - > topic02：A_、B_、C_

私は秩序を維持しようとする1口と1本のボルトを使用しますが、それは動作しません。 OpaqueTridentKafkaSpoutも試しましたが、依頼は変わりました。

この問題を解決するソリューションはありますか？ ありがとうございます。

Answer 1

カフカはパーティション内での注文のみを保証します。パーティションIDにfieldsGroupingを使用し、結果トピックの同じパーティションに結果を書き込むと、Storm内のパーティションごとにこの順序を維持できます。