クラス FilteringBatchMessageListenerAdapter<K,V>
java.lang.ObjectSE
org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter<T>
org.springframework.kafka.listener.adapter.AbstractFilteringMessageListener <K、V、BatchMessageListener <K、V>>
org.springframework.kafka.listener.adapter.FilteringBatchMessageListenerAdapter<K,V>
- 型パラメーター:
K
- 鍵の型。V
- 値の型。
- 実装されたすべてのインターフェース:
BatchAcknowledgingConsumerAwareMessageListener<K,
、V> BatchMessageListener<K,
、V> ConsumerSeekAware
、DelegatingMessageListener<BatchMessageListener<K,
、V>> GenericMessageListener<ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,
V>>>
public class FilteringBatchMessageListenerAdapter<K,V>
extends AbstractFilteringMessageListener<K,V,BatchMessageListener<K,V>>
implements BatchAcknowledgingConsumerAwareMessageListener<K,V>
RecordFilterStrategy
を介してフィルターロジックを実装する BatchMessageListener
アダプター。- 作成者:
- Gary Russell
ネストされたクラスのサマリー
インターフェース org.springframework.kafka.listener.ConsumerSeekAware から継承されたネストクラス / インターフェース
ConsumerSeekAware.ConsumerSeekCallback
フィールドサマリー
クラス org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter から継承されたフィールド
delegate, delegateType, logger
コンストラクターのサマリー
コンストラクターコンストラクター説明FilteringBatchMessageListenerAdapter
(BatchMessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy) 提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。FilteringBatchMessageListenerAdapter
(BatchMessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy, boolean ackDiscarded) 提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。メソッドのサマリー
修飾子と型メソッド説明void
kafka からのデータで呼び出されます。void
onMessage
(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> data, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) kafka からのデータで呼び出され、Consumer
へのアクセスを提供します。void
onMessage
(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> data, Acknowledgment acknowledgment) kafka からのデータで呼び出されます。void
onMessage
(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, 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.BatchMessageListener から継承されたメソッド
onMessage, wantsPollResult
インターフェース org.springframework.kafka.listener.ConsumerSeekAware から継承されたメソッド
onFirstPoll, unregisterSeekCallback
コンストラクターの詳細
FilteringBatchMessageListenerAdapter
public FilteringBatchMessageListenerAdapter(BatchMessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy) 提供された戦略とデリゲートリスナーを使用してインスタンスを作成します。- パラメーター:
delegate
- 代表者。recordFilterStrategy
- フィルター。
FilteringBatchMessageListenerAdapter
public FilteringBatchMessageListenerAdapter(BatchMessageListener<K, V> delegate, RecordFilterStrategy<K, V> recordFilterStrategy, boolean ackDiscarded) Create an instance with the supplied strategy and delegate listener. When 'ackDiscarded' is false, and all messages are filtered, an empty list is passed to the delegate (so it can decide whether or not to ack); when true, a completely filtered batch is ack'd by this class, and no call is made to the delegate.- パラメーター:
delegate
- 代表者。recordFilterStrategy
- フィルター。ackDiscarded
- リスナーが手動 ack 用に構成されている場合に、破棄されたメッセージを ack (コミットオフセット) する場合は true。
メソッドの詳細
onMessage
public void onMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, @Nullable Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) インターフェースからコピーされた説明:GenericMessageListener
kafka からのデータで呼び出され、Consumer
へのアクセスを提供します。デフォルトの実装はUnsupportedOperationException
SE をスローします。- 次で指定:
- インターフェース
BatchAcknowledgingConsumerAwareMessageListener<K,
のV> onMessage
- 次で指定:
- インターフェース
GenericMessageListener<K>
のonMessage
- パラメーター:
records
- 処理されるデータ。acknowledgment
- 承認。consumer
- コンシューマー。
onMessage
インターフェースからコピーされた説明:BatchAcknowledgingConsumerAwareMessageListener
Kafka からのデータを使用して呼び出されます。コンテナーはこれを決して呼び出すべきではありません。コンテナーは、コンシューマーを意識した承認リスナーであることを検出してしまうからです。- 次で指定:
- インターフェース
BatchAcknowledgingConsumerAwareMessageListener<K,
のV> onMessage
- 次で指定:
- インターフェース
GenericMessageListener<K>
のonMessage
- パラメーター:
data
- 処理されるデータ。
onMessage
public void onMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> data, Acknowledgment acknowledgment) インターフェースからコピーされた説明:GenericMessageListener
kafka からのデータで呼び出されます。デフォルトの実装はUnsupportedOperationException
SE をスローします。- 次で指定:
- インターフェース
GenericMessageListener<K>
のonMessage
- パラメーター:
data
- 処理されるデータ。acknowledgment
- 承認。
onMessage
public void onMessage(ListSE<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
- コンシューマー。