Interface KafkaHeaderMapper
-
- All Known Implementing Classes:
AbstractKafkaHeaderMapper
,DefaultKafkaHeaderMapper
,SimpleKafkaHeaderMapper
public interface KafkaHeaderMapper
Header mapper for Apache Kafka.- Since:
- 1.3
- Author:
- Gary Russell
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
fromHeaders(org.springframework.messaging.MessageHeaders headers, org.apache.kafka.common.header.Headers target)
Map from the givenMessageHeaders
to the specified target message.void
toHeaders(org.apache.kafka.common.header.Headers source, java.util.Map<java.lang.String,java.lang.Object> target)
Map from the given target message to abstractedMessageHeaders
.
-
-
-
Method Detail
-
fromHeaders
void fromHeaders(org.springframework.messaging.MessageHeaders headers, org.apache.kafka.common.header.Headers target)
Map from the givenMessageHeaders
to the specified target message.- Parameters:
headers
- the abstracted MessageHeaders.target
- the native target message.
-
toHeaders
void toHeaders(org.apache.kafka.common.header.Headers source, java.util.Map<java.lang.String,java.lang.Object> target)
Map from the given target message to abstractedMessageHeaders
.- Parameters:
source
- the native target message.target
- the target headers.
-
-