Class FullChangeSerde<T>


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

      • wrap

        public static <T> FullChangeSerde<T> wrap​(org.apache.kafka.common.serialization.Serde<T> serde)
      • innerSerde

        public org.apache.kafka.common.serialization.Serde<T> innerSerde()
      • serializeParts

        public Change<byte[]> serializeParts​(java.lang.String topic,
                                             Change<T> data)
      • deserializeParts

        public Change<T> deserializeParts​(java.lang.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).