Linkedin/Confluent did a similar thing with their avro schema registry https://github.com/confluentinc/schema-registry/tree/master/avro-serializer/src/main/java/io/confluent/kafka/serializers which might help
Not sure of the exact answer the to different between Encoder/Serializer though sorry. - Dan On 20 July 2015 at 17:39, Elliot West <[email protected]> wrote: > I'm trying to understand the difference between Encoders/Decoders and > Serializers/Deserializers and when I should be using each. Specifically the > types I'm referring to are: > > - kafka.serializer.Encoder > - kafka.serializer.Decoder > - org.apache.kafka.common.serialization.Serializer > - org.apache.kafka.common.serialization.Deserializer > > Some background: I'd like to append a standard set of metadata to messages > to a number of topics in a manner that is agnostic to their encoding. I was > hoping to do this by providing [en|de]coders that inject/extract the > metadata and then delegate to user supplied [en|de]coders to handle the > encoding of the users actual payload. > > Thanks - Elliot. >
