Kafka Streams を使用して、Kafka トピックで並行作業を行っています。
ストリームは次の形式です
stream(topic)
.map(somefunction)
.through(secondtopic)
15 個のワーカー スレッドを設定KStreams
しましたが、作業がスレッド間で正しくバランスされていないようです (またはまったくバランスが取れていないようです)。私の設定に何か問題があるのでしょうか?作業がワーカー スレッド間で均等に分散されることを期待していましたが、そうではないようです。