👋 Hi everyone! I am new to this community. Currently i am looking for alternative for stream processing(beam+Flink) which i currently using. My Use case: 1.Consume data from eventbus and do the transformation on the fly 2.Store transformed data in to Pinot 3.Notify the changes(updated data) to downstream eventbus Based on documentation i set up my local environment, consumed message from kafka, stored in pinot and performing query from query console. I did not explored how to do the transformation on the fly while consuming data from kafka and how to notify to downstream eventbus? is it possible in current pinot architecture ? or any other workaround to do the same ? Can any one help me?

I am unclear if your usecase needs Pinot, at least from what you describe. Do you just want a store to park intermediate data which consumes from upstream and notifies changes to downstream? It so, that isn’t a use case for Pinot.