クラス 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>
A
AcknowledgingConsumerAwareMessageListener
implementation that looks for a backoff dueTimestamp header and invokes a KafkaConsumerBackoffManager
instance that will back off if necessary.- 導入:
- 2.7
- 作成者:
- Tomaz Fernandes
ネストされたクラスのサマリー
インターフェース org.springframework.kafka.listener.ConsumerSeekAware から継承されたネストクラス / インターフェース
ConsumerSeekAware.ConsumerSeekCallback
フィールドサマリー
クラス org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter から継承されたフィールド
delegate, delegateType, logger
コンストラクターのサマリー
コンストラクターコンストラクター説明KafkaBackoffAwareMessageListenerAdapter
(MessageListener<K, V> delegate, KafkaConsumerBackoffManager kafkaConsumerBackoffManager, StringSE listenerId, StringSE backoffTimestampHeader, ClockSE clock) このリスナーアダプターの構成。KafkaBackoffAwareMessageListenerAdapter
(MessageListener<K, V> adapter, KafkaConsumerBackoffManager kafkaConsumerBackoffManager, StringSE listenerId, ClockSE clock) メソッドのサマリー
修飾子と型メソッド説明void
kafka からのデータで呼び出されます。void
onMessage
(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) kafka からのデータで呼び出され、Consumer
へのアクセスを提供します。void
onMessage
(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> data, Acknowledgment acknowledgment) kafka からのデータで呼び出されます。void
onMessage
(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> consumerRecord, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) kafka からのデータで呼び出され、Consumer
へのアクセスを提供します。クラス org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter から継承されたメソッド
getDelegate, onIdleContainer, onPartitionsAssigned, onPartitionsRevoked, registerSeekCallback
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.kafka.listener.ConsumerSeekAware から継承されたメソッド
onFirstPoll, unregisterSeekCallback
コンストラクターの詳細
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
メソッドの詳細
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
へのアクセスを提供します。デフォルトの実装はUnsupportedOperationException
SE をスローします。- 次で指定:
- インターフェース
AcknowledgingConsumerAwareMessageListener<K,
のV> onMessage
- 次で指定:
- インターフェース
GenericMessageListener<K>
のonMessage
- パラメーター:
consumerRecord
- 処理されるデータ。acknowledgment
- 承認。consumer
- コンシューマー。
onMessage
インターフェースからコピーされた説明: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 からのデータで呼び出されます。デフォルトの実装はUnsupportedOperationException
SE をスローします。- 次で指定:
- インターフェース
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
へのアクセスを提供します。デフォルトの実装はUnsupportedOperationException
SE をスローします。- 次で指定:
- インターフェース
GenericMessageListener<K>
のonMessage
- パラメーター:
data
- 処理されるデータ。consumer
- コンシューマー。