雲のカフカ消費者

Question

私は春のカープカの消費者を使用しています。これは春の起動アプリケーションでラップされ、ピボットクラウドファウンドリのマイクロサービスとして展開されます。私はアプリケーションの15インスタンスを展開しています& 15カフカパーティション。これらのインスタンスのほとんどが1つずつ起動するため、複数のリバランスが実行されますか？カフカのコンシューマーをクラウドに導入するための推奨される方法は何ですか？

Answer 1

新しい0.11クライアントの新しいプロパティはgroup.initial.rebalance.delay.mssee Notable changes in 0.11.0.0です。

新しい設定group.initial.rebalance.delay.msが導入されました。この設定では、GroupCoordinatorが最初のコンシューマリバランスを遅らせる時間をミリ秒単位で指定します。再調整は、新しいメンバーがグループに参加するときにgroup.initial.rebalance.delay.msという値までさらに遅くなります。最大値はmax.poll.interval.msです。これのデフォルト値は3秒です。開発とテストの間、テスト実行時間を遅らさないために0に設定することが望ましいかもしれません。

0.11クライアントのサポートを追加中です。現在、Apache Kafkaの2.0 Spring Springのリリースが予定されていますが、2.0の機能のサブセットを含む1.3リリースと、0.11のサポートが検討されています。

新しいクライアントを古いspring-kafkaで試してみることもできます。それはうまくいくかもしれませんが、トランザクションや0. Headersのような0.11機能は得られません。