Class FullChangeSerde<T>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.FullChangeSerde<T>
-
public final class FullChangeSerde<T> extends Object
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static Change<byte[]>
decomposeLegacyFormattedArrayIntoChangeArrays(byte[] data)
We used to serialize a Change into a single byte[].Change<T>
deserializeParts(String topic, Change<byte[]> serialChange)
Serde<T>
innerSerde()
Change<byte[]>
serializeParts(String topic, Change<T> data)
static <T> FullChangeSerde<T>
wrap(Serde<T> serde)
-
-
-
Method Detail
-
wrap
public static <T> FullChangeSerde<T> wrap(Serde<T> serde)
-
decomposeLegacyFormattedArrayIntoChangeArrays
public static Change<byte[]> decomposeLegacyFormattedArrayIntoChangeArrays(byte[] data)
We used to serialize a Change into a single byte[]. Now, we don't anymore, but we still need to be able to read it (so that we can load the state store from previously-written changelog records).
-
-