Package org.springframework.kafka.support.converter
Package for kafka converters
-
Interface Summary Interface Description BatchMessageConverter A Kafka-specificMessage
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-specificMessage
converter strategy. -
Class Summary Class Description AbstractJavaTypeMapper Abstract type mapper.BatchMessagingMessageConverter A MessagingMessageConverter
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 handlebyte[]
,Bytes
andString
record values.KafkaMessageHeaders Overload of message headers configurable for adding id and timestamp headers.MessagingMessageConverter A MessagingMessageConverter
implementation for a message listener that receives individual messages.ProjectingMessageConverter AMessageConverter
implementation that uses a Spring DataProjectionFactory
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.