You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
An AMQP stream consumer hangs when its local stream is deleted.
Step to reproduce:
spin up a 3-node cluster
create a stream
register an AMQP consumer on one of the nodes with a follower
use rabbitmq-streams delete_replica on the node
publish messages to the stream
the consumer should not receive anything
The consumer reader process is gone and there is no way to recover it as the node does not have a member of the stream anymore, so it should be cancelled/detached.