druid does exactly once ingestion from kafka. The best way to verify this is to load a static dataset into kafka and then ingest into druid and verify row counts.
Vijay Narayanan
02/02/2023, 6:25 AM
The only reason druid data won’t match kafka is if there are parse errors which will be logged (if you have rollup in your ingestion then you need to have “count” as a metric and then do a sum(“count”)