public interface UberSerde<T> extends SerdeWithJson<T>, org.apache.kafka.common.serialization.Serde<T>, org.apache.kafka.common.serialization.Deserializer<T>, org.apache.kafka.common.serialization.Serializer<T>
Modifier and Type | Field and Description |
---|---|
static byte |
MAGIC_BYTE_ORDERED_KEY |
static byte |
MAGIC_BYTE_PROTOBUF |
static byte |
MAGIC_BYTE_STRING |
Modifier and Type | Method and Description |
---|---|
default void |
close()
Close this deserializer.
|
default void |
configure(java.util.Map<java.lang.String,?> configs,
boolean isKey)
Configure this class, which will configure the underlying serializer and deserializer.
|
java.lang.Class<T> |
type() |
deserialize, fromJson, serialize, toJson
deserializer, serializer
static final byte MAGIC_BYTE_PROTOBUF
static final byte MAGIC_BYTE_ORDERED_KEY
static final byte MAGIC_BYTE_STRING
java.lang.Class<T> type()
default void configure(java.util.Map<java.lang.String,?> configs, boolean isKey)
configure
in interface org.apache.kafka.common.serialization.Deserializer<T>
configure
in interface org.apache.kafka.common.serialization.Serde<T>
configure
in interface org.apache.kafka.common.serialization.Serializer<T>
configs
- configs in key/value pairsisKey
- whether is for key or valuedefault void close()
This method must be idempotent as it may be called multiple times.
close
in interface java.lang.AutoCloseable
close
in interface java.io.Closeable
close
in interface org.apache.kafka.common.serialization.Deserializer<T>
close
in interface org.apache.kafka.common.serialization.Serde<T>
close
in interface org.apache.kafka.common.serialization.Serializer<T>