Module serde 

Serde<T>: typed (de)serialization at source/sink boundaries.

Structs

BytesSerde

Identity serde for raw Bytes.

Changed

Serde for Change<V>, byte-compatible with the JVM ChangedSerializer and ChangedDeserializer. Repartition topics use it when a KGroupedTable re-keys.

Consumed

The key and value Serdes that read a topic into the topology.

I64Serde

Big-endian 8-byte i64 serde (matches the JVM Serdes.Long()).

Produced

The key and value Serdes that write a topic from the topology.

SerdeError

Failure to deserialize bytes into T.

StringSerde

UTF-8 String serde.

Enums

SerdeRole

Whether a serde is wired for the record key or the record value. The topology passes this to Serde::prepare, so a schema serde can derive <topic>-key or <topic>-value.

Traits

DefaultSerde

Mapping trait for types that have a default associated Serde.

Serde

Serialize a T to bytes and back. Source nodes deserialize with it, and sink and repartition nodes serialize with it.

SerdeAssociate

Associate a concrete Serde type with its deserialized target type.