Package org.springframework.kafka.support.converter

Interface RecordMessageConverter

All Superinterfaces:
MessageConverter
All Known Implementing Classes:
ByteArrayJsonMessageConverter, BytesJsonMessageConverter, JsonMessageConverter, MessagingMessageConverter, ProjectingMessageConverter, StringJsonMessageConverter
public interface RecordMessageConverter extends MessageConverter
A Kafka-specific Message converter strategy.
Since:
1.1
Author:
Gary Russell

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.kafka.clients.producer.ProducerRecord<?,?>
    fromMessage(Message<?> message, String defaultTopic)
    Convert a message to a producer record.
    Message<?>
    toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Type payloadType)
    Convert a ConsumerRecord to a Message.

    Methods inherited from interface org.springframework.kafka.support.converter.MessageConverter

    commonHeaders

  • Method Details

    • toMessage

      @NonNull Message<?> toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, Type payloadType)
      Convert a ConsumerRecord to a Message.
      Parameters:
      record - the record.
      acknowledgment - the acknowledgment.
      consumer - the consumer
      payloadType - the required payload type.
      Returns:
      the message.

    • fromMessage

      org.apache.kafka.clients.producer.ProducerRecord<?,?> fromMessage(Message<?> message, 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.