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)