rabbitmq-server
rabbitmq-server copied to clipboard
Cancel AMQP stream consumer when local stream member is deleted
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_replicaon 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.
See #4133, #4217