Class FullChangeSerde<T>


  • public final class FullChangeSerde<T>
    extends Object
    • Method Detail

      • innerSerde

        public Serde<T> innerSerde()
      • deserializeParts

        public Change<T> deserializeParts​(String topic,
                                          Change<byte[]> serialChange)
      • 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).