Class JsonSchemaKafkaDeserializer<T>

  • All Implemented Interfaces:
    SchemaParser<com.worldturner.medeia.schema.validation.SchemaValidator>, Closeable, AutoCloseable, org.apache.kafka.common.serialization.Deserializer<T>

    public class JsonSchemaKafkaDeserializer<T>
    extends AbstractKafkaDeserializer<com.worldturner.medeia.schema.validation.SchemaValidator,​T>
    implements org.apache.kafka.common.serialization.Deserializer<T>, SchemaParser<com.worldturner.medeia.schema.validation.SchemaValidator>
    Author:
    eric.wittmann@gmail.com, Ales Justin, Fabian Martinez