how to restart an application which uses kafka without losing messages