インターフェースの使用
org.springframework.kafka.support.KafkaHeaderMapper
KafkaHeaderMapper を使用するパッケージ
パッケージ
説明
リスナーを適応させるためのクラスを提供します。
kafka サポート用パッケージ
kafka コンバーター用パッケージ
org.springframework.kafka.listener.adapter 内の KafkaHeaderMapper 使用
型 KafkaHeaderMapper のパラメーターを持つ org.springframework.kafka.listener.adapter のメソッド修飾子と型メソッド説明voidConvertingMessageListener.setKafkaHeaderMapper(KafkaHeaderMapper headerMapper) KafkaHeaderMapperを設定します。org.springframework.kafka.support 内の KafkaHeaderMapper 使用
KafkaHeaderMapper を実装している org.springframework.kafka.support のクラス修飾子と型クラス説明classKafka ヘッダーマッパーのベース。classApache Kafka のデフォルトのヘッダーマッパー。classヘッダーを直接マップする単純なヘッダーマッパー。送信の場合、byte[] ヘッダーのみがマップされます。受信の場合、ヘッダーは変更されずに byte[] としてマップされます。org.springframework.kafka.support.converter 内の KafkaHeaderMapper 使用
型 KafkaHeaderMapper のパラメーターを持つ org.springframework.kafka.support.converter のメソッド修飾子と型メソッド説明voidBatchMessagingMessageConverter.setHeaderMapper(KafkaHeaderMapper headerMapper) ヘッダーマッパーを設定してヘッダーをマップします。voidMessagingMessageConverter.setHeaderMapper(KafkaHeaderMapper headerMapper) ヘッダーマッパーを設定してヘッダーをマップします。