KubeBlocks
BlogsEnterprise
⌘K
​
Blogs
Open Source · Production-Grade · CNCF Landscape

KubeBlocks RabbitMQ Operator for Kubernetes

Deploy production-grade RabbitMQ clusters on Kubernetes in minutes. Automate HA with quorum queues (Raft replication), and zero-downtime upgrades.

Try Playground Free →Read the Docs

< 30s

Leader Re-election

100%

Open Source

Deploy RabbitMQ in 4 steps

1

Install KubeBlocks

# Add Helm repo
helm repo add kubeblocks https://apecloud.github.io/helm-charts
helm repo update

# Install KubeBlocks
helm install kubeblocks kubeblocks/kubeblocks \
  --namespace kb-system --create-namespace
2

Install RabbitMQ Addon

helm upgrade -i kb-addon-rabbitmq kubeblocks/rabbitmq \
  --namespace kb-system
3

Create a RabbitMQ Cluster

apiVersion: apps.kubeblocks.io/v1
kind: Cluster
metadata:
  name: rabbitmq-cluster
  namespace: demo
spec:
  terminationPolicy: Delete
  componentSpecs:
    - name: rabbitmq
      componentDef: rabbitmq
      serviceVersion: "3.13.7"
      replicas: 3
4

Cluster is Ready

$ kubectl get cluster rabbitmq-cluster -n demo
NAME               CLUSTER-DEFINITION   TERMINATION-POLICY   STATUS    AGE
rabbitmq-cluster                        Delete               Running   2m

Trusted by Engineering Teams at Scale

BONC CloudBONC Cloud
China Mobile CloudChina Mobile Cloud
China Telecom CloudChina Telecom Cloud
TencentTencent
XiaomiXiaomi
Ping AnPing An
VIP.comVIP.com
KwaiKwai
Tiger BrokersTiger Brokers
CITIC SecuritiesCITIC Securities
SealOSSealOS
FastGPTFastGPT
KubeSphereKubeSphere
MomentaMomenta
360360
TilaaTilaa
OlaresOlares
Changan AutomobileChangan Automobile
State GridState Grid
BONC CloudBONC Cloud
China Mobile CloudChina Mobile Cloud
China Telecom CloudChina Telecom Cloud
TencentTencent
XiaomiXiaomi
Ping AnPing An
VIP.comVIP.com
KwaiKwai
Tiger BrokersTiger Brokers
CITIC SecuritiesCITIC Securities
SealOSSealOS
FastGPTFastGPT
KubeSphereKubeSphere
MomentaMomenta
360360
TilaaTilaa
OlaresOlares
Changan AutomobileChangan Automobile
State GridState Grid
RabbitMQ Topology

Production-Grade Cluster. One Operator.

KubeBlocks deploys RabbitMQ as a 3- or 5-node HA cluster. Quorum queues use Raft replication for strong consistency; the cluster itself uses Erlang distributed clustering with Kubernetes peer discovery.

KubeBlocks deploys RabbitMQ as a 3-node (or 5-node) HA cluster. Quorum queues replicate every message to a majority of nodes via Raft before acknowledging the producer. If a queue leader fails, the remaining members elect a new one automatically — no manual intervention required.

✓

Raft consensus — every quorum queue write is replicated to a majority before acknowledged

✓

Automatic leader re-election in under 30 seconds on node failure

✓

All nodes accept AMQP connections — clients reconnect to any surviving node

✓

Peer discovery via Kubernetes Endpoints API (no external etcd or ZooKeeper)

✓

Classic queues and quorum queues supported side-by-side

✓

Management UI on :15672, Prometheus metrics on :15692 per node

Quorum Queues
Raft Consensus
3 or 5 Nodes
AMQP 0-9-1
AMQP ClientsAMQP 0-9-1STOMP / MQTT
↓
rabbitmq-cluster:5672ClusterIP Service
↓
Raft Quorum — 3-node cluster
rabbit-0Leader
:5672:15692
PVC · 20 Gi
rabbit-1Follower
:5672:15692
PVC · 20 Gi
rabbit-2Follower
:5672:15692
PVC · 20 Gi
AMQP:5672
Management UI:15672
Prometheus:15692
Day-2 Operations

Every Operation Declared as a Kubernetes Resource

No SSH into pods, no shell scripts. Submit an OpsRequest and KubeBlocks handles the rest.

Availability & Scaling

✓

Horizontal Scaling

Add or remove nodes (3→5 or 5→3) online. KubeBlocks joins new pods to the RabbitMQ cluster and rebalances queue leaders.

✓

Vertical Scaling

Resize CPU and memory on running nodes with a rolling strategy and no message loss.

✓

Volume Expansion

Expand PVC storage for message data without pod restarts on supported storage classes.

✓

Rolling Restart

Controlled pod restarts that maintain quorum throughout — the cluster stays available.

✓

Stop / Start

Suspend the cluster to eliminate compute cost; resume with full state and quorum intact.

Configuration, Security & Observability

✓

Dynamic Configuration

Apply RabbitMQ parameters via OpsRequest. KubeBlocks applies changes with a rolling pod restart, keeping quorum available throughout.

✓

Credential Management

Admin credentials are auto-generated and stored in Kubernetes Secrets at cluster creation. Update via Secret rotation.

✓

Version Upgrade

Rolling upgrades across supported versions (e.g. 3.13.7 → 4.0.9) with health checks between each pod.

✓

Prometheus Metrics

Per-node metrics on :15692 via the built-in Prometheus plugin. Grafana dashboards available.

✓

Expose via LoadBalancer

Expose AMQP or Management UI externally via a LoadBalancer or NodePort service.

Capabilities

Built for Production RabbitMQ

KubeBlocks automates the hardest parts of running RabbitMQ on Kubernetes — so your team doesn't have to.

Automatic Raft Leader Re-election
When a node fails, the surviving quorum members elect a new quorum queue leader via Raft. KubeBlocks restarts the failed pod and rejoins it — all within 30 seconds.
RTO < 30s
T+0s — Normal
Healthy
rabbit-0
Leader
rabbit-1
Follower
rabbit-2
Follower
T+1s — Failure
Node Down
rabbit-0
Failed
rabbit-1
Follower
rabbit-2
Follower
T+5s — Detect
Detecting
rabbit-0
Unreachable
rabbit-1
Candidate
rabbit-2
Follower
T+12s — Elect
Electing
rabbit-0
Offline
rabbit-1
Elected…
rabbit-2
Follower
T+25s — Recovered
Healthy
rabbit-0
Rejoining
rabbit-1
Leader ★
rabbit-2
Follower
< 30s
Recovery Time (RTO)
0
Manual Steps Required
Raft
Consensus Protocol
No human intervention needed. RabbitMQ's built-in Raft protocol detects the lost quorum member and promotes a new leader. KubeBlocks restarts the failed pod and rejoins it to the cluster automatically.
From the Blog

Go Deeper on RabbitMQ on Kubernetes

We Let an AI Agent Manage Our Databases. Here's Why Most Operators Failed It.

We Let an AI Agent Manage Our Databases. Here's Why Most Operators Failed It.

We tested AI agents against traditional Kubernetes database operators. The results revealed a fundamental mismatch between fragmented operator APIs and how LLMs actually reason.

Validating KubeBlocks Addon High Availability with Chaos Mesh

Validating KubeBlocks Addon High Availability with Chaos Mesh

How to leverage Chaos Mesh for chaos engineering to validate and enhance KubeBlocks' high availability capabilities through systematic fault injection testing.

Managing Over 6,000 Self-Hosted Databases Without a DBA

Managing Over 6,000 Self-Hosted Databases Without a DBA

How Sealos used KubeBlocks to manage 6,000+ self-hosted databases across four availability zones — architecture, HA, backup, and operations.

Get Started

RabbitMQ on Kubernetes, the Easy Way

Deploy a production-grade RabbitMQ cluster in minutes with HA, quorum queues (Raft replication), and full Day-2 operations — all open source.

Try Playground Free →Talk to the Team

© 2026 KUBEBLOCKS INC