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

クラス 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

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

    • 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 へのアクセスを提供します。デフォルトの実装は UnsupportedOperationExceptionSE をスローします。
      次で指定:
      インターフェース BatchAcknowledgingConsumerAwareMessageListener<K,V> の onMessage 
      次で指定:
      インターフェース GenericMessageListener<K> の onMessage 
      パラメーター:
      records - 処理されるデータ。
      acknowledgment - 承認。
      consumer - コンシューマー。

    • onMessage

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