インターフェースの使用
org.springframework.kafka.support.converter.RecordMessageConverter
RecordMessageConverter を使用するパッケージ
パッケージ
説明
kafka 構成のパッケージ
kafka コアコンポーネントのパッケージ
コンシューマーとプロデューサーのためのリアクティブ成分。
リスナーを適応させるためのクラスを提供します。
kafka コンバーター用パッケージ
org.springframework.kafka.config 内の RecordMessageConverter 使用
型 RecordMessageConverter のパラメーターを持つ org.springframework.kafka.config のメソッド修飾子と型メソッド説明voidAbstractKafkaListenerContainerFactory.setRecordMessageConverter(RecordMessageConverter recordMessageConverter) レコードリスナーに動的な引数の型の一致が必要な場合に使用するメッセージコンバーターを設定します。org.springframework.kafka.core 内の RecordMessageConverter 使用
型 RecordMessageConverter のパラメーターを持つ org.springframework.kafka.core のメソッド修飾子と型メソッド説明voidKafkaTemplate.setMessageConverter(RecordMessageConverter messageConverter) 使用するメッセージコンバーターを設定します。org.springframework.kafka.core.reactive 内の RecordMessageConverter 使用
型 RecordMessageConverter のパラメーターを持つ org.springframework.kafka.core.reactive のコンストラクター修飾子コンストラクター説明ReactiveKafkaProducerTemplate(reactor.kafka.sender.KafkaSender<K, V> sender, RecordMessageConverter messageConverter) ReactiveKafkaProducerTemplate(reactor.kafka.sender.SenderOptions<K, V> senderOptions, RecordMessageConverter messageConverter) org.springframework.kafka.listener.adapter 内の RecordMessageConverter 使用
修飾子と型メソッド説明protected final RecordMessageConverterMessagingMessageListenerAdapter.getMessageConverter()Messageを変換できるようにして、このリスナーのMessagingMessageConverterを返します。型 RecordMessageConverter のパラメーターを持つ org.springframework.kafka.listener.adapter のメソッド修飾子と型メソッド説明voidMessagingMessageListenerAdapter.setMessageConverter(RecordMessageConverter messageConverter) MessageConverter を設定します。org.springframework.kafka.support.converter 内の RecordMessageConverter 使用
修飾子と型クラス説明classJSON メッセージコンバーター - 出力の場合はbyte[]、入力の場合は String、Bytes、byte[]。classJSON メッセージコンバーター - 出力の場合はBytes、入力の場合は String、Bytes、byte[]。classclass個々のメッセージを受信するメッセージリスナーのメッセージングMessageConverter実装。classclassJSON メッセージコンバーター - 出力の文字列、入力の文字列、バイト、byte[]。修飾子と型メソッド説明default RecordMessageConverterBatchMessageConverter.getRecordMessageConverter()このバッチコンバーターが使用するレコードコンバーター (構成されている場合) または null を返します。BatchMessagingMessageConverter.getRecordMessageConverter()型 RecordMessageConverter のパラメーターを持つ org.springframework.kafka.support.converter のコンストラクター修飾子コンストラクター説明BatchMessagingMessageConverter(RecordMessageConverter recordConverter) 提供されたコンバーターを使用してレコード値を変換するインスタンスを作成します。