クラス ConsumerStoppingEvent
java.lang.ObjectSE
java.util.EventObjectSE
org.springframework.context.ApplicationEvent
org.springframework.kafka.event.KafkaEvent
org.springframework.kafka.event.ConsumerStoppingEvent
- 実装されたすべてのインターフェース:
SerializableSE
コンシューマーが停止したときに発行されるイベント。ステートレスリスナーを使用するのがベストプラクティスですが、コンテキストイベントマルチキャスタが非同期タスクを使用するように変更されていない限り、このイベントを使用してスレッドベースのリソース (ThreadLocals の削除、スレッドスコープの Bean の破棄など) をクリーンアップできます。実行者。
- 導入:
- 2.2
- 作成者:
- Gary Russell
- 関連事項:
フィールドサマリー
クラス java.util.EventObjectSE から継承されたフィールド
sourceSE
コンストラクターのサマリー
コンストラクターコンストラクター説明ConsumerStoppingEvent
(ObjectSE source, ObjectSE container, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, CollectionSE<org.apache.kafka.common.TopicPartition> partitions) 提供されたソース、コンシューマー、パーティションでインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明org.apache.kafka.clients.consumer.Consumer<?,
?> CollectionSE<org.apache.kafka.common.TopicPartition>
toString()
クラス org.springframework.kafka.event.KafkaEvent から継承されたメソッド
getContainer, getSource
クラス org.springframework.context.ApplicationEvent から継承されたメソッド
getTimestamp
クラス java.util.EventObjectSE から継承されたメソッド
getSource
コンストラクターの詳細
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
toString
- オーバーライド:
- クラス
EventObjectSE
のtoString