I'm working with Kafka data that includes

price

,

instrument

, and

qty

fields. I want to ingest this data into Druid but only save records when the

price

changes. Between each

price

change, I need to aggregate the sum of

qty

(volume). Does anyone have suggestions on how to set this up in Druid? Specifically looking for advice on: 1. Configuring Druid to save data only when price changes 2. Aggregating the sum of qty between these price changes. Any tips on ingestion specs or query examples would be really helpful. Thanks!