steram cannot re-initialize the task

2018-12-28 Thread
Hi, When my application run some time ,there will find a info : No checkpoint found for task 12_1 state store user-share-store-minute changelog flash-app-bch-user-share-store-minute-changelog-1 with EOS turned on. Reinitializing the task and restore its state from the beginning. but ,the applica

stream shutdown error

2018-12-27 Thread
Hi, I am use kafka stream new feature in kafka. My kafka vision : 2.0 My kafka-client vision : 2.1 But i can use the new feature : KIP-328-Final window results per key