2017-06-03 10 views
0

スプリングクラウドストリームは、同じコンシューマグループに属するリアクティブストリームに複数のカフカパーティションを割り当てる方法を教えてください。スプリングクラウドストリームカフカリアクティブストリームパーティション割り当て

単純な非反応性ストリームリスナーを使用すると、コンシューマの同時実行構成によっては、各スレッドが1つのパーティションに割り当てられることに気付きました。一方、ストリーム(Flux入力)の場合、私はそのような並行動作に気付かなかった。すべてのパーティションからのメッセージを処理するストリームは1つしか定義されていないようです。

私は、別のスレッドでバックアップされた同じノード上であっても、それぞれのKafkaトピックパーティションに対して別々のストリームを持つことを期待しています。

答えて