クラス ListenerContainerIdleEvent
java.lang.ObjectSE
java.util.EventObjectSE
org.springframework.context.ApplicationEvent
org.springframework.kafka.event.KafkaEvent
org.springframework.kafka.event.ListenerContainerIdleEvent
- 実装されたすべてのインターフェース:
SerializableSE
コンテナーがアイドル状態になるように構成されている場合に、コンテナーがアイドル状態のときに発生するイベント。
- 作成者:
- Gary Russell
- 関連事項:
フィールドサマリー
クラス java.util.EventObjectSE から継承されたフィールド
sourceSE
コンストラクターのサマリー
コンストラクターコンストラクター説明ListenerContainerIdleEvent
(ObjectSE source, ObjectSE container, long idleTime, StringSE id, CollectionSE<org.apache.kafka.common.TopicPartition> topicPartitions, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, boolean paused) 提供された引数を使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明org.apache.kafka.clients.consumer.Consumer<?,
?> コンシューマーを取得します。long
コンテナーがアイドル状態になっている時間。リスナーの ID (@KafkaListener
の場合) またはコンテナーの Bean 名。CollectionSE<org.apache.kafka.common.TopicPartition>
コンテナーがリッスンしている TopicPartitions。boolean
isPaused()
アイドルイベントが公開されたときにコンシューマーが一時停止された場合は true を返します。toString()
クラス org.springframework.kafka.event.KafkaEvent から継承されたメソッド
getContainer, getSource
クラス org.springframework.context.ApplicationEvent から継承されたメソッド
getTimestamp
クラス java.util.EventObjectSE から継承されたメソッド
getSource
コンストラクターの詳細
ListenerContainerIdleEvent
public ListenerContainerIdleEvent(ObjectSE source, ObjectSE container, long idleTime, StringSE id, CollectionSE<org.apache.kafka.common.TopicPartition> topicPartitions, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, boolean paused) 提供された引数を使用してインスタンスを構築します。- パラメーター:
source
- イベントを生成したコンテナーインスタンス。container
- コンテナーまたはコンテナーが子の場合は親コンテナー。idleTime
- アイドル時間。id
- コンテナー ID。topicPartitions
- 現在割り当てられているトピック / パーティション。consumer
- コンシューマー。paused
- コンシューマーが一時停止している場合は true。- 導入:
- 2.2.1
メソッドの詳細
getIdleTime
public long getIdleTime()コンテナーがアイドル状態になっている時間。- 戻り値:
- ミリ秒単位の時間。
getTopicPartitions
コンテナーがリッスンしている TopicPartitions。- 戻り値:
- TopicPartition リスト。
getListenerId
リスナーの ID (@KafkaListener
の場合) またはコンテナーの Bean 名。- 戻り値:
- ID。
getConsumer
public org.apache.kafka.clients.consumer.Consumer<?,?> getConsumer()コンシューマーを取得します。リスナーがコンシューマーに対応している場合にのみ入力されます。リスナーが一時停止したコンシューマーを再開できるようにします。- 戻り値:
- コンシューマー。
- 導入:
- 2.0
isPaused
public boolean isPaused()アイドルイベントが公開されたときにコンシューマーが一時停止された場合は true を返します。- 戻り値:
- 一時停止。
- 導入:
- 2.1.5
toString
- オーバーライド:
- クラス
EventObjectSE
のtoString