Package org.springframework.kafka.support.converter
package org.springframework.kafka.support.converter
Package for kafka converters
-
ClassDescriptionA Kafka-specific
Message
converter strategy.A MessagingMessageConverter
implementation used with a batch message listener; the consumer record values are extracted into a collection in the message payload.JSON Message converter -byte[]
on output, String, Bytes, or byte[] on input.JSON Message converter -Bytes
on output, String, Bytes, or byte[] on input.Exception for conversions.Base class for JSON message converters; on the consumer side, it can handlebyte[]
,Bytes
andString
record values.Overload of message headers configurable for adding id and timestamp headers.Subclass ofMappingJackson2MessageConverter
that can handle parameterized (generic) types.A top level interface for message converters.A MessagingMessageConverter
implementation for a message listener that receives individual messages.AMessageConverter
implementation that uses a Spring DataProjectionFactory
to bind incoming messages to projection interfaces.A Kafka-specificMessage
converter strategy.JSON Message converter - String on output, String, Bytes, or byte[] on input.