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

クラス ConsumerStoppingEvent

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

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

    • ConsumerStoppingEvent

      public ConsumerStoppingEvent(ObjectSE source, ObjectSE container, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, CollectionSE<org.apache.kafka.common.TopicPartition> partitions)
      提供されたソース、コンシューマー、パーティションでインスタンスを構築します。
      パラメーター:
      source - イベントを生成したコンテナーインスタンス。
      container - コンテナーまたはコンテナーが子の場合は親コンテナー。
      consumer - コンシューマー。
      partitions - パーティション。
      導入:
      2.2.1

  • メソッドの詳細

    • getConsumer

      public org.apache.kafka.clients.consumer.Consumer<?,?> getConsumer()

    • getPartitions

      public CollectionSE<org.apache.kafka.common.TopicPartition> getPartitions()

    • toString

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