インターフェースの使用
org.springframework.kafka.support.converter.MessageConverter
パッケージ
説明
kafka 構成のパッケージ
kafka コンバーター用パッケージ
org.springframework.kafka.config 内の MessageConverter 使用
修飾子と型メソッド説明protected abstract MessagingMessageListenerAdapter<K,
V> AbstractKafkaListenerEndpoint.createMessageListener
(MessageListenerContainer container, MessageConverter messageConverter) 指定されたコンテナーに対してこのエンドポイントを提供できるMessageListener
を作成します。protected MessagingMessageListenerAdapter<K,
V> MethodKafkaListenerEndpoint.createMessageListener
(MessageListenerContainer container, MessageConverter messageConverter) protected MessagingMessageListenerAdapter<K,
V> MethodKafkaListenerEndpoint.createMessageListenerInstance
(MessageConverter messageConverter) 空のMessagingMessageListenerAdapter
インスタンスを作成します。void
AbstractKafkaListenerEndpoint.setupListenerContainer
(MessageListenerContainer listenerContainer, MessageConverter messageConverter) void
KafkaListenerEndpoint.setupListenerContainer
(MessageListenerContainer listenerContainer, MessageConverter messageConverter) このエンドポイントで定義されたモデルを使用して、指定されたメッセージリスナーコンテナーをセットアップします。org.springframework.kafka.support.converter 内の MessageConverter 使用
修飾子と型クラス説明class
バッチメッセージリスナーで使用されるメッセージングMessageConverter
実装。コンシューマーレコードの値は、メッセージペイロードのコレクションに抽出されます。class
JSON メッセージコンバーター - 出力の場合はbyte[]
、入力の場合は String、Bytes、byte[]。class
JSON メッセージコンバーター - 出力の場合はBytes
、入力の場合は String、Bytes、byte[]。class
class
個々のメッセージを受信するメッセージリスナーのメッセージングMessageConverter
実装。class
class
JSON メッセージコンバーター - 出力の文字列、入力の文字列、バイト、byte[]。