I need to transform an encrypted Kafka message before Pinot processes it. Right now for our stream apps we use a custom serde to do it. How can I do it in Pinot? Looks like it would be fairly easy to change Pinot to allow a deserializer to be plugged in. Thoughts?

Is the custom serde on related to the format

Does the decoder get the raw message from the topic? We will need the entire message unaltered. If so are there any docs on how to use a custom decoder?