Currently, if you leave your consumer connected for a while without any activity, at next message the producer will crash (probably socket closed).
We should properly handle dropped connection on consumer side
We should probably close the consumer connection when Final is received, on only reopen it on next Start, so it behave mostly like sarsi-hs and prevent keeping an open socket for no reason.
Currently, if you leave your consumer connected for a while without any activity, at next message the producer will crash (probably socket closed).
Final
is received, on only reopen it on nextStart
, so it behave mostly likesarsi-hs
and prevent keeping an open socket for no reason.