例外のSpring Kafka Stopコンテナ

Question

私はConcurrentMessageListenerContainerを使って自動コミットをfalseに設定して、トピックからのメッセージを消費してデータベースに書き込みます。データベースがダウンしている場合は、コンテナが投票で現在のレコードを処理するのをやめ、次の処理を行わないようにする必要がありますpoll()。 DataSourceHealthIndicatorを実装し、データベースの状態をUPにチェックした後、残りのレコードを処理するためにコンテナを再起動します。

私はどのように残りのレコードの処理を停止してコンテナを停止することができます、私はconsumer.close()を使用しようとしました。しかし、それはプロセスを止めず、消費者を投げつけ続けることはすでに閉鎖されています。

Answer 1

container.stop()を呼び出します。 @KafkaListenerを使用している場合は、リスナーコンテナレジストリのstop()を呼び出して、登録されているすべてのコンテナを停止します。