クラス ConsumerStoppedEvent

java.lang.ObjectSE
java.util.EventObjectSE
org.springframework.context.ApplicationEvent
org.springframework.kafka.event.KafkaEvent
org.springframework.kafka.event.ConsumerStoppedEvent
実装されているすべてのインターフェース:
SerializableSE
public class ConsumerStoppedEvent extends KafkaEvent
コンシューマーが停止したときに公開されるイベント。ステートレスリスナーを使用することをお勧めしますが、コンテキストイベントマルチキャストが非同期タスクを使用するように変更されていない限り、このイベントを使用してスレッドベースのリソースをクリーンアップできます（ThreadLocals の削除、スレッドスコープの Bean の破棄など）。エグゼキュータ。このイベントを使用して、トランザクションプロデューサーがフェンスされたために停止されたコンテナーを再起動することもできます。
導入:
2.2
作成者:
Gary Russell, Lokesh Alamuri
関連事項:

  • コンストラクターの詳細

    • ConsumerStoppedEvent

      public ConsumerStoppedEvent(ObjectSE source, ObjectSE container, ConsumerStoppedEvent.Reason reason)
      提供されたソースとコンテナーでインスタンスを構築します。
      パラメーター:
      source - イベントを生成したコンテナーインスタンス。
      container - コンテナーまたはコンテナーが子の場合は親コンテナー。
      reason - 理由。
      導入:
      2.5.8

  • メソッドの詳細