public class KeyValueSerde<K,V> extends Object
Modifier and Type | Class and Description |
---|---|
static class |
KeyValueSerde.Registry |
Constructor and Description |
---|
KeyValueSerde(String serdeTopic,
org.apache.kafka.common.serialization.Serde<K> keySerde,
org.apache.kafka.common.serialization.Serde<V> valSerde) |
Modifier and Type | Method and Description |
---|---|
K |
deserializeKey(byte[] data) |
V |
deserializeVal(byte[] data) |
static KeyValueSerde.Registry |
newRegistry() |
byte[] |
serializeKey(K key) |
byte[] |
serializeVal(V val) |
public K deserializeKey(byte[] data)
public V deserializeVal(byte[] data)
public byte[] serializeKey(K key)
public byte[] serializeVal(V val)
public static KeyValueSerde.Registry newRegistry()
Copyright © 2020 Red Hat. All rights reserved.