Interface RecordMessageConverter
-
- All Superinterfaces:
MessageConverter
- All Known Implementing Classes:
ByteArrayJsonMessageConverter,BytesJsonMessageConverter,JsonMessageConverter,MessagingMessageConverter,ProjectingMessageConverter,StringJsonMessageConverter
public interface RecordMessageConverter extends MessageConverter
A Kafka-specificMessageconverter strategy.- Since:
- 1.1
- Author:
- Gary Russell
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description org.apache.kafka.clients.producer.ProducerRecord<?,?>fromMessage(org.springframework.messaging.Message<?> message, java.lang.String defaultTopic)Convert a message to a producer record.org.springframework.messaging.Message<?>toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.lang.reflect.Type payloadType)Convert aConsumerRecordto aMessage.-
Methods inherited from interface org.springframework.kafka.support.converter.MessageConverter
commonHeaders
-
-
-
-
Method Detail
-
toMessage
@NonNull org.springframework.messaging.Message<?> toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.lang.reflect.Type payloadType)Convert aConsumerRecordto aMessage.- Parameters:
record- the record.acknowledgment- the acknowledgment.consumer- the consumerpayloadType- the required payload type.- Returns:
- the message.
-
fromMessage
org.apache.kafka.clients.producer.ProducerRecord<?,?> fromMessage(org.springframework.messaging.Message<?> message, java.lang.String defaultTopic)Convert a message to a producer record.- Parameters:
message- the message.defaultTopic- the default topic to use if no header found.- Returns:
- the producer record.
-
-