| 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 | 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 | Description |
|---|---|
| Jackson2JavaTypeMapper.TypePrecedence |
The precedence for type conversion - inferred from the method parameter or message
headers.
|
| Exception | Description |
|---|---|
| ConversionException |
Exception for conversions.
|