This document explains how to deploy a three-node AutoMQ cluster in a local development environment (by deploying MinIO to provide object storage services). In this setup, users can test cluster-related features such as partition reassignment and data auto-balancing. Besides the Docker deployment option, users can reference the following documentation for alternative deployment methods to verify cluster-related features: Additionally, if you’d like to completely bypass the installation and deployment process, you can try the fully managed cloud service provided by the AutoMQ team through the link below. A free two-week trial is available on AWS Marketplace.Documentation Index
Fetch the complete documentation index at: https://docs.automq.com/llms.txt
Use this file to discover all available pages before exploring further.
Prerequisites
- Linux/Mac/Windows Subsystem for Linux
- Docker
- Docker Compose version > 2.22.0
- At least 8GB of available memory
Install and Launch a Three-node AutoMQ Cluster
Use the following command to download the Docker Compose configuration file for the single-node deployment plan and start the single-node AutoMQ cluster using Docker Compose.
Test Message Sending and Receiving.
After installing and starting the AutoMQ cluster, you can test message sending, consumption, and other functionalities by running the following commands.- Execute the following command to create a Topic using the Kafka CLI tool
kafka-topics.shwithin a Docker environment.
- Execute the following command to send test messages using the Kafka CLI tool
kafka-console-producer.shwithin a Docker environment.
- Execute the following command to consume test messages using the Kafka CLI tool
kafka-console-consumer.shwithin a Docker environment.
Explore the Features of the AutoMQ Cluster.
In addition to core message production and consumption features, AutoMQ offers advanced capabilities like second-level partition reassignment and automatic data rebalancing, which address Apache Kafka’s challenges with slow reassignment and scaling. You can refer to the following documentation for testing and validation:- Example: Partition Reassignment in Seconds▸
- Example: Continuous Data Self-Balancing▸
- Example: Self-Balancing When Cluster Nodes Change▸