[druid-user] How does Kafka Firehose find the Kafka offset that is within the window period?

Hi Saksham,

Druid uses high level consumer, you can configure the firehose to either read from the latest offset or the smallest offset.

It will then linearly read all the events from that offset and throw away any events which are outside the windowPeriod.

It does not assumes that the events in kafka topic are ordered by time and no binary search.