Spring Integration Kafka Support

org.springframework.integration.kafka.util
Class MessageUtils

java.lang.Object
  extended by org.springframework.integration.kafka.util.MessageUtils

public class MessageUtils
extends java.lang.Object

Author:
Marius Bogoevici

Constructor Summary
MessageUtils()
           
 
Method Summary
static
<T> T
decodeKey(KafkaMessage message, kafka.serializer.Decoder<T> decoder)
           
static
<T> T
decodePayload(KafkaMessage message, kafka.serializer.Decoder<T> decoder)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MessageUtils

public MessageUtils()
Method Detail

decodeKey

public static <T> T decodeKey(KafkaMessage message,
                              kafka.serializer.Decoder<T> decoder)

decodePayload

public static <T> T decodePayload(KafkaMessage message,
                                  kafka.serializer.Decoder<T> decoder)

Spring Integration Kafka Support