パッケージ org.springframework.kafka.listener.adapter

クラス KafkaBackoffAwareMessageListenerAdapter<K,V>

java.lang.ObjectSE
org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter<MessageListener<K,V>>
org.springframework.kafka.listener.adapter.KafkaBackoffAwareMessageListenerAdapter<K,V>
型パラメーター:
K - レコードキー型。
V - レコード値型。
実装されたすべてのインターフェース:
AcknowledgingConsumerAwareMessageListener<K,V>、ConsumerSeekAware、DelegatingMessageListener<MessageListener<K,V>>、GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>、MessageListener<K,V>
public class KafkaBackoffAwareMessageListenerAdapter<K,V> extends AbstractDelegatingMessageListenerAdapter<MessageListener<K,V>> implements AcknowledgingConsumerAwareMessageListener<K,V>
バックオフ dueTimestamp ヘッダーを探し、必要に応じてバックオフする KafkaConsumerBackoffManager インスタンスを呼び出す AcknowledgingConsumerAwareMessageListener 実装。
導入:
2.7
作成者:
Tomaz Fernandes

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

    • KafkaBackoffAwareMessageListenerAdapter

      public KafkaBackoffAwareMessageListenerAdapter(MessageListener<K,V> delegate, KafkaConsumerBackoffManager kafkaConsumerBackoffManager, StringSE listenerId, StringSE backoffTimestampHeader, ClockSE clock)
      このリスナーアダプターの構成。
      パラメーター:
      delegate - メッセージを処理する MessageListener インスタンス。
      kafkaConsumerBackoffManager - バックオフを処理するマネージャー。
      listenerId - このアダプターに関連付けられているリスナーコンテナーの ID。
      backoffTimestampHeader - タイムスタンプを取得するために受信レコードで検索されるヘッダー名。
      clock - 例外スローのタイムスタンプに使用されるクロックインスタンス。
      導入:
      2.7

    • KafkaBackoffAwareMessageListenerAdapter

      public KafkaBackoffAwareMessageListenerAdapter(MessageListener<K,V> adapter, KafkaConsumerBackoffManager kafkaConsumerBackoffManager, StringSE listenerId, ClockSE clock) throws KafkaBackoffException
      例外:
      KafkaBackoffException

  • メソッドの詳細

    • onMessage

      public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord, @Nullable Acknowledgment acknowledgment, @Nullable org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
      インターフェースからコピーされた説明: GenericMessageListener
      kafka からのデータで呼び出され、Consumer へのアクセスを提供します。デフォルトの実装は UnsupportedOperationExceptionSE をスローします。
      次で指定:
      インターフェース AcknowledgingConsumerAwareMessageListener<K,V> の onMessage 
      次で指定:
      インターフェース GenericMessageListener<K> の onMessage 
      パラメーター:
      consumerRecord - 処理されるデータ。
      acknowledgment - 承認。
      consumer - コンシューマー。

    • onMessage

      public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data)
      インターフェースからコピーされた説明: AcknowledgingConsumerAwareMessageListener
      kafka からのデータで呼び出されます。コンテナーはこれを呼び出してはいけません。なぜなら、コンテナーは、コンシューマー認識の確認応答リスナーであることを検出するからです。
      次で指定:
      インターフェース AcknowledgingConsumerAwareMessageListener<K,V> の onMessage 
      次で指定:
      インターフェース GenericMessageListener<K> の onMessage 
      パラメーター:
      data - 処理されるデータ。

    • onMessage

      public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data, Acknowledgment acknowledgment)
      インターフェースからコピーされた説明: GenericMessageListener
      kafka からのデータで呼び出されます。デフォルトの実装は UnsupportedOperationExceptionSE をスローします。
      次で指定:
      インターフェース GenericMessageListener<K> の onMessage 
      パラメーター:
      data - 処理されるデータ。
      acknowledgment - 承認。

    • onMessage

      public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
      インターフェースからコピーされた説明: GenericMessageListener
      kafka からのデータで呼び出され、Consumer へのアクセスを提供します。デフォルトの実装は UnsupportedOperationExceptionSE をスローします。
      次で指定:
      インターフェース GenericMessageListener<K> の onMessage 
      パラメーター:
      data - 処理されるデータ。
      consumer - コンシューマー。