Hi, Team, a streaming app often does the following: 1. Read local files using flume into kafka 2. Do ETL transformation from kafka topic using flink 3. Pull data from flink into Linkedin's Pinot So, I am not doing direct map from kafka to pinot table just like https://docs.pinot.apache.org/basics/data-import/pinot-stream-ingestion , any suggestion or example can help me, thanks!

You can write the output of Dlink to another Kafka topic for real-time ingest or use Pinot segment generation api to do periodic batch uploads

thanks reply. @Kishore G In reality, I wish to write output of flink/dlink into pinot in memory way.

Pinot does not have a write api as of now...

Sure, I am ready to write the output of Dlink to another Kafka topic for real-time ingest, looking forward to write api 👍