public interface BatchMessageConverter extends MessageConverter
Message converter strategy.| Modifier and Type | Method and Description |
|---|---|
java.util.List<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(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records,
Acknowledgment acknowledgment,
java.lang.reflect.Type payloadType)
Convert a list of
ConsumerRecord to a Message. |
org.springframework.messaging.Message<?> toMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records,
Acknowledgment acknowledgment,
java.lang.reflect.Type payloadType)
ConsumerRecord to a Message.records - the records.acknowledgment - the acknowledgment.payloadType - the required payload type.java.util.List<org.apache.kafka.clients.producer.ProducerRecord<?,?>> fromMessage(org.springframework.messaging.Message<?> message,
java.lang.String defaultTopic)
message - the message.defaultTopic - the default topic to use if no header found.