Tranquility commit offsets

I am consuming from kafka through tranquility. When does tranquility commit offsets?

If I dont consume from tranquility and use a realtime node with kafka firehose, when does it store offsets?

Hey Rishi,

Tranquility-kafka’s commit period is controlled by ‘commit.periodMillis’ which defaults to every 15 seconds. When the commit period elapses, Tranquility-kafka halts reading, forces Tranquility to flush any retained messages to Druid, and then commits the offset to Kafka, after which point reading is resumed.

The Kafka firehose commits the offset after a persist (write contents of memory to disk), the frequency of which is controlled by ‘maxRowsInMemory’ and ‘intermediatePersistPeriod’.