Kafka Streams: why aren't offsets being committed?

[Dmitry Minkovsky]

My Streams application is configured to commit offsets every 250ms:

        Properties streamsConfig = new Properties();
        streamsConfig.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 250);


However, every time I restart my application, records that have already
been processed are re-processed, even if the application has not had data
for a long time.

My guess is that offsets are committed only when all tasks in the topology
have received input. Is this what's happening?



Thank you,
Dmitry