Interface KafkaHeaderMapper
-
- All Known Implementing Classes:
AbstractKafkaHeaderMapper,DefaultKafkaHeaderMapper,SimpleKafkaHeaderMapper
public interface KafkaHeaderMapperHeader mapper for Apache Kafka.- Since:
- 1.3
- Author:
- Gary Russell
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidfromHeaders(org.springframework.messaging.MessageHeaders headers, org.apache.kafka.common.header.Headers target)Map from the givenMessageHeadersto the specified target message.voidtoHeaders(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 givenMessageHeadersto 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.
-
-