RABBITMQ-STREAMS(8) System Manager's Manual RABBITMQ-STREAMS(8) (NAME) rabbitmq-streams - RabbitMQ (SYNOPSIS) rabbitmq-streams [-q] [-s] [-l] [-n node] [-t timeout] command [command_options] (DESCRIPTION) rabbitmq-streams (replicas) . : RabbitMQ: https://www.rabbitmq.com/docs/streams. (OPTIONS) -n node "rabbit@target-hostname " target-hostname . "myserver.example.com " "rabbit@myserver" ( RABBITMQ_NODENAME ). "hostname -s" "@" . RabbitMQ rabbitmq-server(8) . -q, --quiet (quiet) . . -s, --silent (silent) . . -t timeout, --timeout timeout . . infinity . -l, --longnames (FQDN) . RabbitMQ: https://www.rabbitmq.com/docs/clustering . --erlang-cookie cookie (shared secret) . RABBITMQ_ERLANG_COOKIE . RabbitMQ: https://www.rabbitmq.com/docs/cli . (COMMANDS) help rabbitmq-streams . (Replication) add_replica queue node --vhost virtual-host (replica) . : rabbitmq-streams add_replica --vhost "a-vhost" "a-queue" "rabbit@new-node" delete_replica queue node --vhost virtual-host (replica) . : rabbitmq-streams delete_replica --vhost "a-vhost" "a-queue" "rabbit@decomissioned-node" (Monitoring, observability and health checks) stream_status stream --vhost virtual-host . : rabbitmq-streams stream_status --vhost "a-vhost" "a-stream" restart_stream stream --vhost virtual-host --preferred-leader-node node . (leader) . : rabbitmq-streams restart_stream --vhost "a-vhost" "a-stream" --preferred-leader-node "node" (Stream plugin) activate_stream_consumer --stream stream --reference reference [--vhost vhost] (rebalancing) . : rabbitmq-streams activate_stream_consumer --stream stream --reference app-1 list_stream_connections [connectioninfoitem ...] . connectioninfoitem . . connectioninfoitem : auth_mechanism SASL "PLAIN". client_properties . conn_name . connected_at (timestamp). connection_state : o running o blocked frame_max (). heartbeat (heartbeat) . host DNS IP DNS . peer_cert_issuer SSL (peer) RFC4514. peer_cert_subject SSL RFC4514. peer_cert_serial_number SSL . peer_cert_validity SSL . peer_host DNS IP DNS . peer_port . port . ssl SSL . ssl_cipher SSL ( "aes_256_cbc"). ssl_hash SSL ( "sha"). ssl_key_exchange SSL ( "rsa"). ssl_protocol SSL ( "tlsv1"). subscriptions () . user . vhost (vhost) ASCII C . connectioninfoitem conn_name . : rabbitmq-streams list_stream_connections conn_name user list_stream_consumers [-p vhost] [consumerinfoitem ...] . consumerinfoitem . . consumerinfoitem : active . activity_status : o up o single_active o waiting connection_pid (Erlang process ID) . credits . messages_consumed . offset ( ) . offset_lag . properties . stream . subscription_id (connection-scoped ID) . consumerinfoitem connection_pid subscription_id stream messages_consumed offset offset_lag credits active activity_status properties . PID : rabbitmq-streams list_stream_consumers connection_pid subscription_id stream list_stream_publishers [-p vhost] [publisherinfoitem ...] (publishers) . publisherinfoitem . . publisherinfoitem : connection_pid . messages_confirmed . messages_errored . messages_published . publisher_id . reference (deduplication reference) . stream . publisherinfoitem connection_pid publisher_id stream reference messages_published messages_confirmed messages_errored . PID : rabbitmq-streams list_stream_publishers connection_pid publisher_id stream add_super_stream super-stream [--vhost vhost] [--partitions partitions] [--binding-keys binding-keys] [--max-length-bytes max-length-bytes] [--max-age max-age] [--stream-max-segment-size-bytes stream-max-segment-size-bytes] [--leader-locator leader-locator] [--initial-cluster-size initial-cluster-size] super-stream (super stream) . vhost . partitions . binding-keys (binding keys). max-length-bytes : 20gb, 500mb. max-age ISO 8601 PT10M30S P5DT8H . stream-max-segment-size-bytes : 500mb, 1gb. leader-locator (leader locator) . : o client-local o balanced balanced . initial-cluster-size . . delete_super_stream super-stream [--vhost vhost] . super-stream . vhost . list_stream_consumer_groups [-p vhost] [groupinfoitem ...] vhost . groupinfoitem . . groupinfoitem : consumers . partition_index 1- . reference ( ). stream . groupinfoitem stream reference partition_index consumers . : rabbitmq-streams list_stream_consumer_groups stream reference consumers list_stream_group_consumers --stream stream --reference reference [--vhost vhost] [consumerinfoitem ...] vhost . stream . reference ( ). vhost . consumerinfoitem . . consumerinfoitem : connection_name . state : o active o inactive subscription_id . consumerinfoitem subscription_id connection_name state . stream-1 stream-1 : rabbitmq-streams list_stream_group_consumers --stream stream-1 --reference stream-1 connection_name state list_stream_tracking stream [--all | --offset | --writer] [--vhost vhost] . stream . : --all (writer deduplication). --offset . --writer . : rabbitmq-streams list_stream_tracking stream-1 --offset reset_offset --stream stream --reference reference [--vhost vhost] . : rabbitmq-streams reset_offset --stream stream --reference app-1 (SEE ALSO) rabbitmqctl(8), rabbitmq-diagnostics(8), rabbitmq-server(8), rabbitmq-queues(8), rabbitmq-upgrade(8), rabbitmq-service(8), rabbitmq-env.conf(5) (AUTHORS) The RabbitMQ Team RabbitMQ Server July 1, 2025 RabbitMQ Server