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