Hey Everyone! Just getting started with Pinot. Is there any example on how to use custom decoder during stream ingestion? I am following this example https://docs.pinot.apache.org/basics/getting-started/pushing-your-streaming-data-to-pinot. My data is in custom binary format. Looks like I have to implement

org.apache.pinot.spi.stream.StreamMessageDecoder

. Any reference code example would be helpful?

You could look at the exiting ones that are implemented in the code base.