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

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

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

    • 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 へのアクセスを提供します。デフォルトの実装は 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 - コンシューマー。