5

Kafka Streams を使用して、Kafka トピックで並行作業を行っています。

ストリームは次の形式です

stream(topic)
 .map(somefunction)
 .through(secondtopic)

15 個のワーカー スレッドを設定KStreamsしましたが、作業がスレッド間で正しくバランスされていないようです (またはまったくバランスが取れていないようです)。私の設定に何か問題があるのでしょうか?作業がワーカー スレッド間で均等に分散されることを期待していましたが、そうではないようです。

jvisualvm からのスナップショット

4

1 に答える 1