Skip to Main Content

Example: Simple Benchmark

This article aims to guide you through a simple message sending and receiving workload to verify the core features of AutoMQ.

After successfully installing AutoÏQ using the Cluster Deployment on Linux▸ method, you will receive a list of Bootstrap Server addresses similar to the following:,

If you installed via Deploy Locally▸, the Bootstrap Server address will be:


Throughout all steps, please ensure to replace the Bootstrap Server address with the one you actually obtained.


  • Linux/Mac/Windows Subsystem for Linux

  • Docker

If the container image download is slow, please refer to Docker Hub Mirror Configuration▸

Create Topic

CMD='docker run --network automq_net automqinc/automq:latest /bin/bash -c "/opt/kafka/kafka/bin/ --create --topic test-topic --bootstrap-server broker1:9092,broker2:9092"'; [ "$(uname)" = "Linux" ] && eval "sudo $CMD" || eval $CMD

Send Message

CMD='docker run --network automq_net automqinc/automq:latest /bin/bash -c "/opt/kafka/kafka/bin/ --topic test-topic --num-records=1024000 --throughput 5120 --record-size 1024 --producer-props bootstrap.servers=broker1:9092,broker2:9092"'; [ "$(uname)" = "Linux" ] && eval "sudo $CMD" || eval $CMD

Consume Message

CMD='docker run --network automq_net automqinc/automq:1.0.4 /bin/bash -c "/opt/kafka/kafka/bin/ --topic test-topic --show-detailed-stats --timeout 300000 --messages=1024000 --reporting-interval 1000 --bootstrap-server=broker1:9092,broker2:9092"'; [ "$(uname)" = "Linux" ] && eval "sudo $CMD" || eval $CMD