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

クラス NonResponsiveConsumerEvent

java.lang.ObjectSE
java.util.EventObjectSE
org.springframework.context.ApplicationEvent
org.springframework.kafka.event.KafkaEvent
org.springframework.kafka.event.NonResponsiveConsumerEvent
実装されたすべてのインターフェース:
SerializableSE
public class NonResponsiveConsumerEvent extends KafkaEvent
コンシューマーが投票に応答していないときに発行されるイベント。kafka-clients の初期バージョンでは、これはブローカーがダウンしていることを示している可能性があります。
導入:
1.3.1
作成者:
Gary Russell
関連事項:

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

    • NonResponsiveConsumerEvent

      public NonResponsiveConsumerEvent(ObjectSE source, ObjectSE container, long timeSinceLastPoll, StringSE id, CollectionSE<org.apache.kafka.common.TopicPartition> topicPartitions, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
      提供されたプロパティを使用してインスタンスを構築します。
      パラメーター:
      source - イベントを生成したコンテナーインスタンス。
      container - コンテナーまたはコンテナーが子の場合は親コンテナー。
      timeSinceLastPoll - 前回の投票からの時間。
      id - コンテナー ID。
      topicPartitions - トピックのパーティション。
      consumer - コンシューマー。
      導入:
      2.2.1

  • メソッドの詳細

    • getTimeSinceLastPoll

      public long getTimeSinceLastPoll()
      前回の投票からの経過時間。
      戻り値:
      ミリ秒単位の時間。

    • 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()
      コンシューマーを取得します。リスナーがコンシューマーに対応している場合にのみ入力されます。リスナーが一時停止したコンシューマーを再開できるようにします。
      戻り値:
      コンシューマー。

    • toString

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