hi everyone,

why my streaming app after each restart it start over reprocessing the data ?

are you using the same consumer group id on each run?

you can inspect the underlying infrastructure by asking kafka for its consumer offsets, and looking at your consumer id

if you run your app, you should see your consumer's offset increment, and it should be reused the next time you run and only go up