Hi, The issue is not that i cannot get a custom deserializer working, it's that the custom deserializer i provide implements the default method from the Deserializer interface https://github.com/apache/kafka/blob/6f0008643db6e7299658442784f1bcc6c96395ed/clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java#L59 that gives access to record Headers.
The kafka console consumer never calls this method, it will only call the variant without Headers https://github.com/apache/kafka/blob/6f0008643db6e7299658442784f1bcc6c96395ed/clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java#L50 I'm using kafka 2.3.0 btw. Jorg On 2019/11/12 11:58:26, "M. Manna" <manme...@gmail.com> wrote: > > I think you can try the following to get your implementation working > > 1) Provide the SerDe classes into classpath > 2) Provide your consumer config file > 3) Provide key/value Deserializer props via --consumer-property arg. >
