Hi kafka users,

since upgrading to kafka 2.1.1 version I get the following log message at every 
startup of streaming services:
"No checkpoint found for task 0_16 state store TestStore changelog 
test-service-TestStore-changelog-16 with EOS turned on. Reinitializing the task 
and restore its state from the beginning".

Is there any configuration that I have to set so that checkpoints are created?

Thanks in advance.

Best,
Claudi

Reply via email to