パッケージ org.springframework.kafka.event

クラス ShareConsumerStoppingEvent

java.lang.ObjectSE
java.util.EventObjectSE
org.springframework.context.ApplicationEvent
org.springframework.kafka.event.KafkaEvent
org.springframework.kafka.event.ShareConsumerStoppingEvent
実装済みのインターフェース一覧:
SerializableSE
public class ShareConsumerStoppingEvent extends KafkaEvent
共有コンシューマーが停止する際に発行されるイベントです。ステートレスリスナーを使用するのがベストプラクティスですが、コンテキストイベントマルチキャスターが非同期タスクエグゼキュータを使用するように変更されていない限り、このイベントを使用してスレッドベースのリソースをクリーンアップ（ThreadLocals の削除、スレッドスコープの Bean の破棄など）することができます。
導入:
4.1
作成者:
Youngjoo Kim
関連事項:

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

    • ShareConsumerStoppingEvent

      public ShareConsumerStoppingEvent(ObjectSE source, ObjectSE container, org.apache.kafka.clients.consumer.ShareConsumer<?,?> consumer)
      指定されたソース、コンテナー、共有コンシューマーを使用してインスタンスを構築します。
      パラメーター:
      source - イベントを生成したコンテナーインスタンス。
      container - コンテナーまたはコンテナーが子の場合は親コンテナー。
      consumer - シェアコンシューマー。

  • 方法の詳細

    • getConsumer

      public org.apache.kafka.clients.consumer.ShareConsumer<?,?> getConsumer()
      Return the share consumer.
      戻り値:
      シェアコンシューマー。

    • toString

      public StringSE toString()
      オーバーライド:
      クラス EventObjectSE の toString