Skip to content

Cancel AMQP stream consumer when local stream member is deleted #11915

@acogoluegnes

Description

@acogoluegnes

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

Metadata

Metadata

Assignees

Labels

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions