Uses of Interface
org.springframework.kafka.support.converter.RecordMessageConverter
Package
Description
Package for kafka core components
Reactive component for consumer and producer.
Provides classes for adapting listeners.
Package for kafka converters
-
Uses of RecordMessageConverter in org.springframework.kafka.core
Modifier and TypeMethodDescriptionKafkaTemplate.getMessageConverter()
Return the message converter.Modifier and TypeMethodDescriptionvoid
KafkaTemplate.setMessageConverter
(RecordMessageConverter messageConverter) Set the message converter to use. -
Uses of RecordMessageConverter in org.springframework.kafka.core.reactive
ModifierConstructorDescriptionReactiveKafkaProducerTemplate
(reactor.kafka.sender.SenderOptions<K, V> senderOptions, RecordMessageConverter messageConverter) -
Uses of RecordMessageConverter in org.springframework.kafka.listener.adapter
Modifier and TypeMethodDescriptionprotected final RecordMessageConverter
MessagingMessageListenerAdapter.getMessageConverter()
Return theMessagingMessageConverter
for this listener, being able to convertMessage
.Modifier and TypeMethodDescriptionvoid
MessagingMessageListenerAdapter.setMessageConverter
(RecordMessageConverter messageConverter) Set the MessageConverter. -
Uses of RecordMessageConverter in org.springframework.kafka.support.converter
Modifier and TypeClassDescriptionclass
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.Modifier and TypeMethodDescriptiondefault RecordMessageConverter
BatchMessageConverter.getRecordMessageConverter()
Return the record converter used by this batch converter, if configured, or null.BatchMessagingMessageConverter.getRecordMessageConverter()
ModifierConstructorDescriptionBatchMessagingMessageConverter
(RecordMessageConverter recordConverter) Create an instance that converts record values using the supplied converter.