Committing is independent of process and/or punctuate. You can configure your Kafka Streams application commit interval to any value you like via `commit.interval.ms` parameter (default is 30 seconds).
Thus, there is no guarantee when a commit exactly happens with regard to calling process and punctuate. -Matthias On 10/22/17 11:43 PM, Tobias Adamson wrote: > Hi > What is the contract around Processor.process and punctuate. > > When will Kafka streams commit the offset > After the process method is called successfully or not until punctuate is > called? > > Regards > Toby >
signature.asc
Description: OpenPGP digital signature
