クラス FilteringMessageListenerAdapter<K,V>
java.lang.ObjectSE
org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter<T>
org.springframework.kafka.listener.adapter.AbstractFilteringMessageListener <K、V、MessageListener <K、V>>
org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter<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 FilteringMessageListenerAdapter<K,V>
extends AbstractFilteringMessageListener<K,V,MessageListener<K,V>>
implements AcknowledgingConsumerAwareMessageListener<K,V>
RecordFilterStrategy
を介してフィルターロジックを実装する MessageListener
アダプター。- 作成者:
- Gary Russell
ネストされたクラスのサマリー
インターフェース org.springframework.kafka.listener.ConsumerSeekAware から継承されたネストクラス / インターフェース
ConsumerSeekAware.ConsumerSeekCallback
フィールドサマリー
クラス org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter から継承されたフィールド
delegate, delegateType, logger
コンストラクターのサマリー
コンストラクターコンストラクター説明FilteringMessageListenerAdapter
(MessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy) 提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。FilteringMessageListenerAdapter
(MessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy, boolean ackDiscarded) 提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。メソッドのサマリー
修飾子と型メソッド説明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.AbstractFilteringMessageListener から継承されたメソッド
filter, getRecordFilterStrategy
クラス 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
コンストラクターの詳細
FilteringMessageListenerAdapter
public FilteringMessageListenerAdapter(MessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy) 提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。- パラメーター:
delegate
- 代表者。recordFilterStrategy
- フィルター。
FilteringMessageListenerAdapter
public FilteringMessageListenerAdapter(MessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy, boolean ackDiscarded) 提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。- パラメーター:
delegate
- 代表者。recordFilterStrategy
- フィルター。ackDiscarded
- リスナーが手動 ack 用に構成されている場合に、破棄されたメッセージを ack (コミットオフセット) する場合は true。
メソッドの詳細
onMessage
public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> consumerRecord, @Nullable Acknowledgment acknowledgment, 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
- コンシューマー。