Package org.springframework.kafka.support.converter

Package for kafka converters

Interface Summary

Interface	Description
BatchMessageConverter	A Kafka-specific Message converter strategy.
ClassMapper	Strategy for setting metadata on messages such that one can create the class that needs to be instantiated when receiving a message.
Jackson2JavaTypeMapper	Strategy for setting metadata on messages such that one can create the class that needs to be instantiated when receiving a message.
MessageConverter	A top level interface for message converters.
RecordMessageConverter	A Kafka-specific Message converter strategy.

Class Summary

Class	Description
AbstractJavaTypeMapper	Abstract type mapper.
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.
DefaultJackson2JavaTypeMapper	Jackson 2 type mapper.
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.
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.

Enum Summary

Enum	Description
Jackson2JavaTypeMapper.TypePrecedence	The precedence for type conversion - inferred from the method parameter or message headers.

Exception Summary

Exception	Description
ConversionException	Exception for conversions.