Hi, I think the best way here would be to read items directly from kafka, process and store in cache and rememeber in another cache kafka stream offset. If node crashes, your service could start from the last point (offset).
Thanks! -Dmitry -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/
