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

クラス ConvertingMessageListener<V>

java.lang.ObjectSE
org.springframework.kafka.listener.adapter.ConvertingMessageListener<V>
型パラメーター:
V - 変換後の目的の値の型。
実装されたすべてのインターフェース:
AcknowledgingConsumerAwareMessageListener<ObjectSE,ObjectSE>、DelegatingMessageListener<MessageListener>、GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<ObjectSE,ObjectSE>>、MessageListener<ObjectSE,ObjectSE>
public class ConvertingMessageListener<V> extends ObjectSE implements DelegatingMessageListener<MessageListener>, AcknowledgingConsumerAwareMessageListener<ObjectSE,ObjectSE>
指定された MessageConverter を使用して受信した ConsumerRecord の変換を実装し、結果を指定された MessageListener に渡す AcknowledgingConsumerAwareMessageListener アダプター。直接設定する場合、ヘッダーも KafkaHeaderMapper の実装でマップし、実際に処理されるメッセージの一部としてコンバーターに渡すことができます。それ以外の場合、ヘッダーマッパーが指定されていない場合、コンバーターの観点からはヘッダーにアクセスできません。
導入:
3.0
作成者:
Adrian Chlebosz
関連事項:

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

    • ConvertingMessageListener

      public ConvertingMessageListener(MessageListener<?,V> delegateMessageListener, ClassSE<V> desiredValueType)
      提供された MessageListener および ClassSE を、変換後の ConsumerRecord の値の目的の型として使用してインスタンスを構築します。MessageConverter のデフォルト値である GenericMessageConverter が使用されます。
      パラメーター:
      delegateMessageListener - 変換された ConsumerRecord をさらに渡すときに使用する MessageListener。
      desiredValueType - ClassSE 設定 ConsumerRecord の値の必要な型。

  • メソッドの詳細

    • setMessageConverter

      public void setMessageConverter(MessageConverter messageConverter)
      MessageConverter を設定します。
      パラメーター:
      messageConverter - 受信 ConsumerRecord の変換に使用するメッセージコンバーター。
      導入:
      3.0

    • setKafkaHeaderMapper

      public void setKafkaHeaderMapper(KafkaHeaderMapper headerMapper)
      KafkaHeaderMapper を設定します。
      パラメーター:
      headerMapper - 受信 ConsumerRecord のヘッダーのマッピングに使用するヘッダーマッパー。
      導入:
      3.0

    • getDelegate

      public MessageListener getDelegate()
      インターフェースからコピーされた説明: DelegatingMessageListener
      代理人を返します。
      次で指定:
      インターフェース DelegatingMessageListener<V> の getDelegate 
      戻り値:
      代表者。

    • onMessage

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