kafkaクラスターがダウンした後に@KafkaListenerが無限ループに入ります

Question

私は3ノードのkafkaクラスターを持っています。私はdebezium（kafka-mysqlコネクター）を使用しています。
トピックコンシューマとして@KafkaListenerというメソッドを記述します。
その後、手動でkafkaクラスタをシャットダウンします（kill -15）。

その後、リスナーは突然無限ループに陥ります。

topコマンド

jstack

と消費者のログ（無限）

これはバグですか？例外を受け入れることは可能ですが、CPU使用率が100％に達することは望ましくありません。

Answer 1

これは、基礎となるkafkaクライアントの0.11.0.0までの動作です。

reconnect.backoff.msプロパティが0.11.0.0クライアント（CommonClientConfigs.RETRY_BACKOFF_MS_CONFIG）に追加されました。KAFKA-5766とkafka documentationを参照してください。

スプリングカフカ1.3.xは、0.11クライアント（および2.0.x）を使用します。 Spring Kafka 2.1.xは現在の1.0.0クライアントを使用します。