Not able to use StremMessage Class MetaData information from decoder class (JSONMessageDecoder)

[prasad-maladi]

I am writing plugin to decode the kafka message, but the decoder class doesn't have access to the StreamMessage metadata information.
Is there possibility to decode the message using metadata information?

[Jackie-Jiang]

cc @swaminathanmanish @KKcorps

[Jackie-Jiang]

Ideally decoder should be decoupled from stream type, but seems we also have coupled decoders such as KafkaAvroMessageDecoder. How do you plan to use the metadata within the decoder?

[prasad-maladi]

payload is encryted in our case, we have properties which can decrypt the payload in metadata object. StreamMassage has metadata object, but I can't really use in my decoder.