Class JsonSchemaKafkaSerializer<T>

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

    public class JsonSchemaKafkaSerializer<T>
    extends AbstractKafkaSerializer<com.worldturner.medeia.schema.validation.SchemaValidator,​T>
    implements org.apache.kafka.common.serialization.Serializer<T>, SchemaParser<com.worldturner.medeia.schema.validation.SchemaValidator>
    An implementation of the Kafka Serializer for JSON Schema use-cases. This serializer assumes that the user's application needs to serialize a Java Bean to JSON data using Jackson. In addition to standard serialization of the bean, this implementation can also optionally validate it against a JSON schema.
    Author:
    eric.wittmann@gmail.com, Ales Justin, Fabian Martinez