設定ウィンドウ[ホッピング、タンブリングなど]カフカストリームの並列性

Question

kafkaストリームでホッピングウィンドウコードを書いています。minMaxCalculator()は、ストリーム内の最小値と最大値を一度キーでグループ化しています。

KTable<Windowed<String>, aggrTest> WinMinMax = Records.groupByKey().aggregate(new aggrTestInitilizer(), 
     new minMaxCalculator() 
     , TimeWindows.of(TimeUnit.SECONDS.toMillis(5)).advanceBy(TimeUnit.SECONDS.toMillis(1)),aggrMessageSerde,"aggr-test"); 

は、キーによるIグループたら、私は1つカフカパーティションがある場合でも並列内のすべてのキーのために生成されたウィンドウを処理したいです。どうすればこのことができますか？ は、この並列性をウィンドウに対応して設定できますか？

Answer 1

並列性は入力パーティションに基づいており、異なることはできません。したがって、設定できるパラメータはありません。

ただし、パーティションの所望の数にトピックを作成し、through()を使用して手動で再パーティション化のためにそれを使用することができます。

stream.through("multi-partition-topic").groupByKey()... 

は、より多くの詳細については、ドキュメントをチェックアウト：

• https://docs.confluent.io/current/streams/architecture.html#parallelism-model
を
• https://docs.confluent.io/current/streams/developer-guide/manage-topics.html#user-topics