実行時にスプリングカフカプロデューサを正常にシャットダウンします

Question

spring-kafkaを使用する春の起動アプリケーションがあります。 configプロパティを更新するときに、kafkaプロデューサ（kafkatemplate）を無効にしたいとします。私は条件付きのBeanを試して、applicationcontext refreshを使っています。

spring-kafkaでkafkaproducerを正常にシャットダウンする方法はありますか？

Answer 1

DefaultKafkaProducerFactoryでdestroy()を呼び出して（シングルトン）プロデューサを閉じることができますが、次にコードがcreateProducer()を呼び出すと別のものが作成されます。現在、それを防ぐ方法はありません。ファクトリをサブクラス化し、プロデューサを作成したくない場合は例外をスローする必要があります。