インターフェースの使用
org.springframework.kafka.support.converter.MessageConverter
MessageConverter を使用するパッケージ
パッケージ
説明
kafka 構成のパッケージ
kafka コンバーター用パッケージ
org.springframework.kafka.config 内の MessageConverter 使用
型 MessageConverter のパラメーターを持つ org.springframework.kafka.config のメソッド修飾子と型メソッド説明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インスタンスを作成します。voidAbstractKafkaListenerEndpoint.setupListenerContainer(MessageListenerContainer listenerContainer, MessageConverter messageConverter) voidKafkaListenerEndpoint.setupListenerContainer(MessageListenerContainer listenerContainer, MessageConverter messageConverter) このエンドポイントで定義されたモデルを使用して、指定されたメッセージリスナーコンテナーをセットアップします。org.springframework.kafka.support.converter 内の MessageConverter 使用
org.springframework.kafka.support.converter 内の MessageConverter サブインターフェース修飾子と型クラス説明classバッチメッセージリスナーで使用されるメッセージングMessageConverter実装。コンシューマーレコードの値は、メッセージペイロードのコレクションに抽出されます。classJSON メッセージコンバーター - 出力の場合はbyte[]、入力の場合は String、Bytes、byte[]。classJSON メッセージコンバーター - 出力の場合はBytes、入力の場合は String、Bytes、byte[]。classclass個々のメッセージを受信するメッセージリスナーのメッセージングMessageConverter実装。classclassJSON メッセージコンバーター - 出力の文字列、入力の文字列、バイト、byte[]。