Hello Giridhar,
I'm not totally sure but what you've described seems to be
https://issues.apache.org/jira/browse/KAFKA-8187 (I do remember some
similar bugs resulting in state directory cleanup incorrectly in the old
versions). Could you maybe try out newer version and see if this is fixed?
Guoz
We are using kakfa streams version 1.1.0
We made some changes to kafka streams code. We are observing following sequence
of events in our production environment. We want to understand if following
sequence of events is possible in 1.1.0 version also.
time T0
StreamThread-1 : got assigned 0_1,
