クラス RecordMessagingMessageListenerAdapter<K,V>
java.lang.ObjectSE
org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter<K,V>
org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter<K,V>
- 型パラメーター:
K- 鍵の型。V- 値の型。
- 実装されたすべてのインターフェース:
AcknowledgingConsumerAwareMessageListener<K,、V> AsyncRepliesAware、ConsumerSeekAware、GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,、V>> MessageListener<K,V>
public class RecordMessagingMessageListenerAdapter<K,V>
extends MessagingMessageListenerAdapter<K,V>
implements AcknowledgingConsumerAwareMessageListener<K,V>
構成可能な
HandlerAdapter を呼び出す MessageListener アダプター。リスナーが個々のメッセージを受信するようにファクトリが構成されている場合に使用されます。 受信 Kafka メッセージを Spring の Message 抽象化にラップします。
元の ConsumerRecord と Acknowledgment は追加の引数として提供されているため、必要に応じてこれらをメソッド引数として挿入できます。
- 作成者:
- Stephane Nicoll, Gary Russell, Artem Bilan, Venil Noronha
ネストされたクラスのサマリー
クラス org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter から継承されたネストクラス / インターフェース
MessagingMessageListenerAdapter.ReplyExpressionRootインターフェース org.springframework.kafka.listener.ConsumerSeekAware から継承されたネストクラス / インターフェース
ConsumerSeekAware.ConsumerSeekCallbackフィールドサマリー
クラス org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter から継承されたフィールド
logger, NULL_MESSAGEコンストラクターのサマリー
コンストラクターコンストラクター説明RecordMessagingMessageListenerAdapter(ObjectSE bean, MethodSE method) RecordMessagingMessageListenerAdapter(ObjectSE bean, MethodSE method, KafkaListenerErrorHandler errorHandler) メソッドのサマリー
修飾子と型メソッド説明voidonMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) KafkaAcknowledgingConsumerAwareMessageListenerエントリポイント。クラス org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter から継承されたメソッド
acknowledge, asyncFailure, asyncSuccess, createMessagingErrorMessage, determineInferredType, getMessageConverter, getReplyHeadersConfigurer, getType, handleException, handleResult, invoke, invokeHandler, isAsyncReplies, isConsumerRecordList, isConsumerRecords, isConversionNeeded, isMessageList, isSplitIterables, onIdleContainer, onPartitionsAssigned, onPartitionsRevoked, registerSeekCallback, sendResponse, setBeanResolver, setCorrelationHeaderName, setFallbackType, setHandlerMethod, setMessageConverter, setMessagingConverter, setReplyHeadersConfigurer, setReplyTemplate, setReplyTopic, setSplitIterables, toMessagingMessageクラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース org.springframework.kafka.listener.AcknowledgingConsumerAwareMessageListener から継承されたメソッド
onMessageインターフェース org.springframework.kafka.listener.ConsumerSeekAware から継承されたメソッド
onFirstPoll, unregisterSeekCallbackインターフェース org.springframework.kafka.listener.GenericMessageListener から継承されたメソッド
onMessage, onMessage
コンストラクターの詳細
RecordMessagingMessageListenerAdapter
RecordMessagingMessageListenerAdapter
public RecordMessagingMessageListenerAdapter(ObjectSE bean, MethodSE method, @Nullable KafkaListenerErrorHandler errorHandler)
メソッドの詳細
onMessage
public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K, V> record, @Nullable Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) KafkaAcknowledgingConsumerAwareMessageListenerエントリポイント。メッセージ引数を適切に変換して、メッセージをターゲットリスナーメソッドに委譲します。
- 次で指定:
- インターフェース
AcknowledgingConsumerAwareMessageListener<K,のV> onMessage - 次で指定:
- インターフェース
GenericMessageListener<K>のonMessage - パラメーター:
record- 受信 KafkaConsumerRecord。acknowledgment- 承認。consumer- コンシューマー。