Uses of Interface
org.springframework.kafka.support.converter.MessageConverter
Package
Description
Package for kafka configuration
Package for kafka converters
-
Uses of MessageConverter in org.springframework.kafka.config
Modifier and TypeMethodDescriptionprotected abstract MessagingMessageListenerAdapter<K,
V> AbstractKafkaListenerEndpoint.createMessageListener
(MessageListenerContainer container, MessageConverter messageConverter) Create aMessageListener
that is able to serve this endpoint for the specified container.protected MessagingMessageListenerAdapter<K,
V> MethodKafkaListenerEndpoint.createMessageListener
(MessageListenerContainer container, MessageConverter messageConverter) protected MessagingMessageListenerAdapter<K,
V> MethodKafkaListenerEndpoint.createMessageListenerInstance
(MessageConverter messageConverter) Create an emptyMessagingMessageListenerAdapter
instance.void
AbstractKafkaListenerContainerFactory.setMessageConverter
(MessageConverter messageConverter) Deprecated.void
AbstractKafkaListenerEndpoint.setupListenerContainer
(MessageListenerContainer listenerContainer, MessageConverter messageConverter) void
KafkaListenerEndpoint.setupListenerContainer
(MessageListenerContainer listenerContainer, MessageConverter messageConverter) Setup the specified message listener container with the model defined by this endpoint. -
Uses of MessageConverter in org.springframework.kafka.support.converter
Modifier and TypeInterfaceDescriptioninterface
A Kafka-specificMessage
converter strategy.interface
A Kafka-specificMessage
converter strategy.Modifier and TypeClassDescriptionclass
A MessagingMessageConverter
implementation used with a batch message listener; the consumer record values are extracted into a collection in the message payload.class
JSON Message converter -byte[]
on output, String, Bytes, or byte[] on input.class
JSON Message converter -Bytes
on output, String, Bytes, or byte[] on input.class
Base class for JSON message converters; on the consumer side, it can handlebyte[]
,Bytes
andString
record values.class
A MessagingMessageConverter
implementation for a message listener that receives individual messages.class
AMessageConverter
implementation that uses a Spring DataProjectionFactory
to bind incoming messages to projection interfaces.class
JSON Message converter - String on output, String, Bytes, or byte[] on input.
AbstractKafkaListenerContainerFactory.setBatchMessageConverter(BatchMessageConverter)
andAbstractKafkaListenerContainerFactory.setRecordMessageConverter(RecordMessageConverter)
.