class NativeSerde<T> : BaseSerde<T>
NativeSerde decorates Kafka Serdes and allows direct access to its Serializer and Deserializer functions.
T - is the concrete type the decorated Serde is able to serialize and
deserialize.
inner - Serde to decorate with the BaseSerde interface.
See Also
NativeSerde(inner: Serde<T>)
NativeSerde decorates Kafka Serdes and allows direct access to its Serializer and Deserializer functions. |
fun doDeserialize(topic: String, data: ByteArray): T
Extending classes must implement this function to convert the ByteArray back to its original type T. |
|
fun doSerialize(topic: String, data: T): ByteArray
Extending classes must implement this method to convert data of type T to a ByteArray. |
open fun close(): Unit
Close this Serde/Serializer/Deserializer and frees any currently held resources. This method must be idempotent because it might be called multiple times. |
|
open fun configure(config: Map<String, *>, isKey: Boolean): Unit
Configure this object, which will configure the underlying Serializer and Deserializer. |
|
fun deserialize(topic: String, data: ByteArray?): T?
|
|
fun deserializer(): Deserializer<T>
Get the underlying Deserializer |
|
fun serialize(topic: String, data: T?): ByteArray?
|
|
fun serializer(): Serializer<T>
Get the underlying Serializer |