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