新しいカフカコンシューマのための同等のプロパティ `num.consumer.fetchers`

カフカの古いコンシューマコンフィグでは、データをフェッチするために使用される番号フェッチャスレッドを設定するために、プロパティnum.consumer.fetchersがあります。カフカの新しいコンシューマ設定で、同じ機能を持つプロパティがありますか？そうでなければ、新しい消費者はどのようにそれに取り組んでいますか？新しいカフカコンシューマのための同等のプロパティ `num.consumer.fetchers`

出典

2017-01-19 jjmo

新しいコンシューマはシングルスレッド（バックグラウンドハートビートスレッドを除く）なので、同等の設定は提供されません。

ところで、 'num.consumer.fetchers'は、ドキュメントが言うようにフェッチャスレッドの数を指定しません。 Kafkaが作成できるフェッチャスレッドの最大数を実際に制御します。

出典

2017-01-19 02:09:49 amethystic

大丈夫です！その場合、より速い方法でメッセージを消費することができるので、より多くの消費者、複数のクライアントをインスタンス化する必要がありますか？ – jjmo

同じコンシューマグループ内の複数のコンシューマには異なるパーティションが割り当てられるため、コンシューマ番号を追加するだけでは役に立ちません。これを実現するためにカフカが提供する設定オプションを調整する必要があります。実際、メッセージ消費はイベント処理よりもはるかに高速なので、後者を改善するために多くの努力がなされています。 – amethystic

新しいカフカコンシューマのための同等のプロパティ `num.consumer.fetchers`

答えて

関連する問題