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

クラス BatchMessagingMessageListenerAdapter<K,V>

java.lang.ObjectSE
org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter<K,V>
org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter<K,V>
型パラメーター:
K - 鍵の型。
V - 値の型。
実装されたすべてのインターフェース:
AsyncRepliesAware、BatchAcknowledgingConsumerAwareMessageListener<K,V>、BatchMessageListener<K,V>、ConsumerSeekAware、GenericMessageListener<ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>>
public class BatchMessagingMessageListenerAdapter<K,V> extends MessagingMessageListenerAdapter<K,V> implements BatchAcknowledgingConsumerAwareMessageListener<K,V>
構成可能な HandlerAdapter を呼び出す MessageListener アダプター。リスナーがメッセージのバッチを受信するようにファクトリが構成されている場合に使用されます。

受信 Kafka メッセージを Spring の Message 抽象化にラップします。

元の List<ConsumerRecord> と Acknowledgment は追加の引数として提供されているため、必要に応じてこれらをメソッド引数として挿入できます。

導入:
1.1
作成者:
Stephane Nicoll, Gary Russell, Artem Bilan, Venil Noronha, Wang ZhiYang

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

    • BatchMessagingMessageListenerAdapter

      public BatchMessagingMessageListenerAdapter(ObjectSE bean, MethodSE method)
      指定されたパラメーターを使用してインスタンスを作成します。
      パラメーター:
      bean - リスナー Bean。
      method - リスナーメソッド。

    • BatchMessagingMessageListenerAdapter

      public BatchMessagingMessageListenerAdapter(ObjectSE bean, MethodSE method, @Nullable KafkaListenerErrorHandler errorHandler)
      指定されたパラメーターを使用してインスタンスを作成します。
      パラメーター:
      bean - リスナー Bean。
      method - リスナーメソッド。
      errorHandler - エラーハンドラー。

  • メソッドの詳細

    • setBatchMessageConverter

      public void setBatchMessageConverter(BatchMessageConverter messageConverter)
      BatchMessageConverter を設定します。
      パラメーター:
      messageConverter - コンバーター。

    • setBatchToRecordAdapter

      public void setBatchToRecordAdapter(BatchToRecordAdapter<K,V> batchToRecordAdapter)
      BatchToRecordAdapter を設定します。
      パラメーター:
      batchToRecordAdapter - アダプター。
      導入:
      2.4.2

    • getBatchMessageConverter

      protected final BatchMessageConverter getBatchMessageConverter()
      Message を変換できるようにして、このリスナーの BatchMessagingMessageConverter を返します。
      戻り値:
      このリスナーの BatchMessagingMessageConverter。Message を変換できます。

    • wantsPollResult

      public boolean wantsPollResult()
      インターフェースからコピーされた説明: BatchMessageListener
      このリスナーが ConsumerRecord のリストの代わりに元の ConsumerRecords オブジェクトを受け取りたい場合は true を返します。
      次で指定:
      インターフェース BatchMessageListener<K,V> の wantsPollResult 
      戻り値:
      コンシューマーレコードの場合は true。

    • onMessage

      public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> records, @Nullable Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
      インターフェースからコピーされた説明: BatchMessageListener
      リスナーは、ConsumerRecord のリストの代わりに、元の ConsumerRecords オブジェクトを受け取ります。
      次で指定:
      インターフェース BatchMessageListener<K,V> の onMessage 
      パラメーター:
      records - 記録。
      acknowledgment - 承認 (手動 ACK でない場合は null)
      consumer - コンシューマー。

    • onMessage

      public void onMessage(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records, @Nullable Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
      Kafka MessageListener エントリポイント。

      メッセージ引数を適切に変換して、メッセージをターゲットリスナーメソッドに委譲します。

      次で指定:
      インターフェース BatchAcknowledgingConsumerAwareMessageListener<K,V> の onMessage 
      次で指定:
      インターフェース GenericMessageListener<K> の onMessage 
      パラメーター:
      records - Kafka ConsumerRecord の受信リスト。
      acknowledgment - 承認。
      consumer - コンシューマー。

    • toMessagingMessage

      protected Message<?> toMessagingMessage(ListSE records, @Nullable Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)