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

クラス ConsumerPausedEvent

java.lang.ObjectSE
java.util.EventObjectSE
org.springframework.context.ApplicationEvent
org.springframework.kafka.event.KafkaEvent
org.springframework.kafka.event.ConsumerPausedEvent
実装されたすべてのインターフェース:
SerializableSE
public class ConsumerPausedEvent extends KafkaEvent
コンシューマーが一時停止したときに発行されるイベント。
導入:
2.1.5
作成者:
Gary Russell
関連事項:

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

    • ConsumerPausedEvent

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

    • ConsumerPausedEvent

      public ConsumerPausedEvent(ObjectSE source, ObjectSE container, CollectionSE<org.apache.kafka.common.TopicPartition> partitions, StringSE reason)
      提供されたソースとパーティションでインスタンスを構築します。
      パラメーター:
      source - イベントを生成したコンテナーインスタンス。
      container - コンテナーまたはコンテナーが子の場合は親コンテナー。
      partitions - パーティション。
      reason - 一時停止の理由。
      導入:
      2.8.9

  • メソッドの詳細

    • getPartitions

      public CollectionSE<org.apache.kafka.common.TopicPartition> getPartitions()
      一時停止したパーティションを返します。
      戻り値:
      パーティション。

    • toString

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