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

クラス ListenerContainerIdleEvent

java.lang.ObjectSE
java.util.EventObjectSE
org.springframework.context.ApplicationEvent
org.springframework.kafka.event.KafkaEvent
org.springframework.kafka.event.ListenerContainerIdleEvent
実装されたすべてのインターフェース:
SerializableSE
public class ListenerContainerIdleEvent extends KafkaEvent
コンテナーがアイドル状態になるように構成されている場合に、コンテナーがアイドル状態のときに発生するイベント。
作成者:
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<?,?>
    getConsumer()
    コンシューマーを取得します。
    long
    getIdleTime()
    コンテナーがアイドル状態になっている時間。
    StringSE
    getListenerId()
    リスナーの ID ( @KafkaListener の場合) またはコンテナーの Bean 名。
    CollectionSE<org.apache.kafka.common.TopicPartition>
    getTopicPartitions()
    コンテナーがリッスンしている TopicPartitions。
    boolean
    isPaused()
    アイドルイベントが公開されたときにコンシューマーが一時停止された場合は true を返します。
    StringSE
    toString()

    クラス org.springframework.kafka.event.KafkaEvent から継承されたメソッド

    getContainer, getSource

    クラス org.springframework.context.ApplicationEvent から継承されたメソッド

    getTimestamp

    クラス java.util.EventObjectSE から継承されたメソッド

    getSource

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSE

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

    • 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

      public CollectionSE<org.apache.kafka.common.TopicPartition> getTopicPartitions()
      コンテナーがリッスンしている TopicPartitions。
      戻り値:
      TopicPartition リスト。

    • getListenerId

      public StringSE 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

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