K - the key type.V - the value type.public interface MessageConverter<K,V>
Message converter strategy.| Modifier and Type | Method and Description |
|---|---|
org.springframework.messaging.Message<?> |
toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record,
Acknowledgment acknowledgment) |
org.springframework.messaging.Message<?> toMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, Acknowledgment acknowledgment)