public class MessageUtils
extends java.lang.Object
Constructor and Description |
---|
MessageUtils() |
Modifier and Type | Method and Description |
---|---|
static <T> T |
decodeKey(KafkaMessage message,
kafka.serializer.Decoder<T> decoder) |
static <T> T |
decodePayload(KafkaMessage message,
kafka.serializer.Decoder<T> decoder) |
public static <T> T decodeKey(KafkaMessage message, kafka.serializer.Decoder<T> decoder)
public static <T> T decodePayload(KafkaMessage message, kafka.serializer.Decoder<T> decoder)