rabbitmq-server icon indicating copy to clipboard operation
rabbitmq-server copied to clipboard

Cancel AMQP stream consumer when local stream member is deleted

Open acogoluegnes opened this issue 1 year ago • 0 comments

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.

See #4133, #4217

acogoluegnes avatar Aug 06 '24 12:08 acogoluegnes