クラス 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) メソッドのサマリー
修飾子と型メソッド説明void
onMessage
(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
- コンシューマー。