Kafka で複数のパーティションを注文することはできず、パーティションの注文はグループ内の単一のコンシューマー (単一のパーティション) に対してのみ保証されることを認識しています。しかし、Kafka Streams 0.10 でこれを達成できるようになりましたか? タイムスタンプ機能を使用して各パーティションの各メッセージがコンシューマ側で順序を維持する場合、Kafka Streams 0.10 でこれが可能になったとしましょう。すべてのメッセージを受け取ったと仮定すると、消費されたタイムスタンプに基づいてすべてのパーティションをソートし、それらを別のトピックに転送して消費することはできないでしょうか?
現時点では、順序を維持する必要がありますが、これは、1 つのコンシューマー スレッドを持つ 1 つのパーティションを持つことを意味します。これを複数のパーティションに変更して並列処理を増やしたいと思っていましたが、どういうわけか「それらを順番に取得」しました。
何かご意見は？ありがとうございました。