Package org.springframework.kafka.support.converter

Package for kafka converters

Interface Summary

Interface	Description
BatchMessageConverter	A Kafka-specific Message converter strategy.
MessageConverter	A top level interface for message converters.
RecordMessageConverter	A Kafka-specific Message converter strategy.

Class Summary

Class	Description
BatchMessagingMessageConverter	A Messaging MessageConverter implementation used with a batch message listener; the consumer record values are extracted into a collection in the message payload.
ByteArrayJsonMessageConverter	JSON Message converter - byte[] on output, String, Bytes, or byte[] on input.
BytesJsonMessageConverter	JSON Message converter - Bytes on output, String, Bytes, or byte[] on input.
JsonMessageConverter	Base class for JSON message converters; on the consumer side, it can handle byte[], Bytes and String record values.
KafkaMessageHeaders	Overload of message headers configurable for adding id and timestamp headers.
MappingJacksonParameterizedConverter	Subclass of MappingJackson2MessageConverter that can handle parameterized (generic) types.
MessagingMessageConverter	A Messaging MessageConverter implementation for a message listener that receives individual messages.
ProjectingMessageConverter	A MessageConverter implementation that uses a Spring Data ProjectionFactory to bind incoming messages to projection interfaces.
StringJsonMessageConverter	JSON Message converter - String on output, String, Bytes, or byte[] on input.

Exception Summary

Exception	Description
ConversionException	Exception for conversions.