Hi,
On Mon, 11 Nov 2019 at 10:58, Jorg Heymans <jorg.heym...@gmail.com> wrote:
> Hi,
>
> I have created a class implementing Deserializer, providing an
> implementation for
>
> public String deserialize(String topic, Headers headers, byte[] data)
>
> that does some conditional processing based on headers, and then calls the
> other serde method
>
> public String deserialize(String topic, byte[] data)
>
> What i'm seeing is that kafka-console-consumer only uses the second method
> when a value deserializer is specified. Is there a way to force it to
> invoke the first method, so i can do processing with headers ? I tried
> implementing the deprecated 'ExtendedSerializer' but it does not make a
> difference.
>
> Thanks,
> Jorg
>
Have you tried providing a separate prop file using consumer.config
argument? Please see the reference here:
--consumer.config <String: config file> Consumer config properties file.
Note
that [consumer-property] takes
precedence over this config.
Try that and see how it goes.
Thanks,
