Class SubscriptionResponseWrapperSerde<V>

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, org.apache.kafka.common.serialization.Serde<SubscriptionResponseWrapper<V>>

    public class SubscriptionResponseWrapperSerde<V>
    extends java.lang.Object
    implements org.apache.kafka.common.serialization.Serde<SubscriptionResponseWrapper<V>>
    • Constructor Detail

      • SubscriptionResponseWrapperSerde

        public SubscriptionResponseWrapperSerde​(org.apache.kafka.common.serialization.Serde<V> foreignValueSerde)
    • Method Detail

      • serializer

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

        public org.apache.kafka.common.serialization.Deserializer<SubscriptionResponseWrapper<V>> deserializer()
        Specified by:
        deserializer in interface org.apache.kafka.common.serialization.Serde<V>