Class WrappingNullableSerde<T,​InnerK,​InnerV>

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, org.apache.kafka.common.serialization.Serde<T>
    Direct Known Subclasses:
    SubscriptionWrapperSerde, ValueAndTimestampSerde

    public abstract class WrappingNullableSerde<T,​InnerK,​InnerV>
    extends java.lang.Object
    implements org.apache.kafka.common.serialization.Serde<T>
    • Method Detail

      • serializer

        public org.apache.kafka.common.serialization.Serializer<T> serializer()
        Specified by:
        serializer in interface org.apache.kafka.common.serialization.Serde<T>
      • deserializer

        public org.apache.kafka.common.serialization.Deserializer<T> deserializer()
        Specified by:
        deserializer in interface org.apache.kafka.common.serialization.Serde<T>
      • configure

        public void configure​(java.util.Map<java.lang.String,​?> configs,
                              boolean isKey)
        Specified by:
        configure in interface org.apache.kafka.common.serialization.Serde<T>
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Specified by:
        close in interface org.apache.kafka.common.serialization.Serde<T>
      • setIfUnset

        public void setIfUnset​(org.apache.kafka.common.serialization.Serde<InnerK> defaultKeySerde,
                               org.apache.kafka.common.serialization.Serde<InnerV> defaultValueSerde)