Class CustomDeserializer<T>

java.lang.Object
energy.eddie.outbound.kafka.CustomDeserializer<T>
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.common.serialization.Deserializer<T>

public class CustomDeserializer<T> extends Object implements org.apache.kafka.common.serialization.Deserializer<T>
  • Constructor Details

  • Method Details

    • deserialize

      @Nullable public T deserialize(String topic, byte[] data)
      Specified by:
      deserialize in interface org.apache.kafka.common.serialization.Deserializer<T>