org.springframework.kafka.support

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

Modifier and Type	Method and Description
void	fromHeaders(org.springframework.messaging.MessageHeaders headers, org.apache.kafka.common.header.Headers target) Map from the given MessageHeaders 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 abstracted MessageHeaders.

Method Detail

fromHeaders

void fromHeaders(org.springframework.messaging.MessageHeaders headers,
                 org.apache.kafka.common.header.Headers target)

Map from the given MessageHeaders 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 abstracted MessageHeaders.

Parameters:

source - the native target message.

target - the target headers.