K
- key type of serdesV
- value type of serdespublic final class Serdes<K,V>
extends java.lang.Object
Constructor and Description |
---|
Serdes(java.lang.String topic,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Serializer<V> valueSerializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
Create a context for serialization using the specified serializers and deserializers which
must match the key and value types used as parameters for this object.
|
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Deserializer<K> |
keyDeserializer() |
K |
keyFrom(byte[] rawKey) |
org.apache.kafka.common.serialization.Serializer<K> |
keySerializer() |
byte[] |
rawKey(K key) |
byte[] |
rawValue(V value) |
java.lang.String |
topic() |
org.apache.kafka.common.serialization.Deserializer<V> |
valueDeserializer() |
V |
valueFrom(byte[] rawValue) |
org.apache.kafka.common.serialization.Serializer<V> |
valueSerializer() |
static <K,V> Serdes<K,V> |
withBuiltinTypes(java.lang.String topic,
java.lang.Class<K> keyClass,
java.lang.Class<V> valueClass) |
public Serdes(java.lang.String topic, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Serializer<V> valueSerializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
topic
- the name of the topickeySerializer
- the serializer for keys; may be nullkeyDeserializer
- the deserializer for keys; may be nullvalueSerializer
- the serializer for values; may be nullvalueDeserializer
- the deserializer for values; may be nullpublic static <K,V> Serdes<K,V> withBuiltinTypes(java.lang.String topic, java.lang.Class<K> keyClass, java.lang.Class<V> valueClass)
public org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer()
public org.apache.kafka.common.serialization.Serializer<K> keySerializer()
public org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer()
public org.apache.kafka.common.serialization.Serializer<V> valueSerializer()
public java.lang.String topic()
public K keyFrom(byte[] rawKey)
public V valueFrom(byte[] rawValue)
public byte[] rawKey(K key)
public byte[] rawValue(V value)