|
Role
|
Action
|
Permission Level and Applicable Scenarios
|
|---|---|---|
|
InstanceViewer
|
Instance:ListInstances
|
|
|
Instance:GetInstance
|
||
|
Instance:GetInstanceMetadata
|
||
|
Instance:ListInstanceACLPolicies
|
||
|
Instance:ListInstanceACLUsers
|
||
|
ConsumerGroup:ListConsumerGroups
|
||
|
ConsumerGroup:GetConsumerGroup
|
||
|
Topic:GetTopic
|
||
|
Topic:ListTopics
|
||
|
Profile:GetDeployProfile
|
||
|
Profile:ListDeployProfiles
|
||
|
KafkaLinking:ListKafkaLinks
|
||
|
KafkaLinking:GetKafkaLink
|
||
|
InstanceDeveloper
|
Instance:GetInstance
|
|
|
Instance:ListInstances
|
||
|
Instance:ListInstanceACLPolicies
|
||
|
Instance:CreateInstanceACLPolicy
|
||
|
Instance:DeleteInstanceACLPolicy
|
||
|
Instance:GetInstanceMetadata
|
||
|
Instance:ListInstanceACLUsers
|
||
|
Instance:CreateInstanceACLUser
|
||
|
Instance:DeleteInstanceACLUser
|
||
|
ConsumerGroup:ListConsumerGroups
|
||
|
ConsumerGroup:CreateConsumerGroup
|
||
|
ConsumerGroup:GetConsumerGroup
|
||
|
ConsumerGroup:UpdateConsumerGroup
|
||
|
ConsumerGroup:DeleteConsumerGroup
|
||
|
Topic:ListTopics
|
||
|
Topic:CreateTopic
|
||
|
Topic:GetTopic
|
||
|
Topic:DeleteTopic
|
||
|
Topic:UpdateTopic
|
||
|
Topic:CreateMessage
|
||
|
Profile:GetDeployProfile
|
||
|
Profile:ListDeployProfiles
|
||
|
Environment:GetMessage
|
||
|
InstanceAdmin
|
Instance:GetInstance
|
|
|
Instance:ListInstances
|
||
|
Instance:UpdateInstance
|
||
|
Instance:GetInstanceMetadata
|
||
|
Instance:DeleteInstance
|
||
|
Instance:UpdateInstanceIntegration
|
||
|
Instance:ListInstanceACLUsers
|
||
|
Instance:CreateInstanceACLUser
|
||
|
Instance:DeleteInstanceACLUser
|
||
|
Instance:ListInstanceACLPolicies
|
||
|
Instance:CreateInstanceACLPolicy
|
||
|
Instance:DeleteInstanceACLPolicy
|
||
|
ConsumerGroup:ListConsumerGroups
|
||
|
ConsumerGroup:CreateConsumerGroup
|
||
|
ConsumerGroup:GetConsumerGroup
|
||
|
ConsumerGroup:UpdateConsumerGroup
|
||
|
ConsumerGroup:DeleteConsumerGroup
|
||
|
Topic:CreateTopic
|
||
|
Topic:GetTopic
|
||
|
Topic:DeleteTopic
|
||
|
Topic:UpdateTopic
|
||
|
Topic:ListTopics
|
||
|
Topic:CreateMessage
|
||
|
Profile:GetDeployProfile
|
||
|
Profile:ListDeployProfiles
|
||
|
Environment:GetMessage
|
||
|
Integration:ListIntegrations
|
||
|
Integration:ListIntegrationTypes
|
||
|
KafkaLinking:CreateKafkaLink
|
||
|
KafkaLinking:ListKafkaLinks
|
||
|
KafkaLinking:GetKafkaLink
|
||
|
KafkaLinking:DeleteKafkaLink
|
||
|
IntegrationAdmin
|
Integration:UpdateInstanceIntegration
|
|
|
Integration:ListIntegrations
|
||
|
Integration:GetIntegration
|
||
|
Integration:UpdateIntegration
|
||
|
Integration:DeleteIntegration
|
||
|
Integration:ListIntegrationTypes
|
||
|
Profile:ListDeployProfiles
|
||
|
Profile:GetDeployProfile
|
||
|
EnvironmentViewer
|
Instance:GetInstance
|
|
|
Instance:ListInstances
|
||
|
Instance:ListInstanceACLPolicies
|
||
|
Instance:GetInstanceMetadata
|
||
|
Instance:ListInstanceACLUsers
|
||
|
ConsumerGroup:ListConsumerGroups
|
||
|
ConsumerGroup:GetConsumerGroup
|
||
|
Topic:ListTopics
|
||
|
Topic:GetTopic
|
||
|
Integration:ListIntegrations
|
||
|
Integration:GetIntegration
|
||
|
Integration:ListIntegrationTypes
|
||
|
Migration:ListMigrations
|
||
|
Migration:GetMigration
|
||
|
Profile:ListDeployProfiles
|
||
|
Profile:GetDeployProfile
|
||
|
Environment:ListProductVersions
|
||
|
Environment:ListProviders
|
||
|
Environment:ListRegions
|
||
|
Environment:ListZones
|
||
|
Environment:ListSubnets
|
||
|
Environment:ListNodeGroups
|
||
|
Environment:GetNodeGroup
|
||
|
Environment:GetEnvironment
|
||
|
KafkaLinking:ListKafkaLinks
|
||
|
KafkaLinking:GetKafkaLink
|
||
|
EnvironmentOperator
|
Instance:GetInstance
|
|
|
Instance:ListInstances
|
||
|
Instance:ListInstanceACLPolicies
|
||
|
Instance:CreateInstanceACLPolicy
|
||
|
Instance:DeleteInstanceACLPolicy
|
||
|
Instance:CreateInstance
|
||
|
Instance:UpdateInstance
|
||
|
Instance:DeleteInstance
|
||
|
Instance:GetInstanceMetadata
|
||
|
Instance:UpdateInstanceIntegration
|
||
|
Instance:ListInstanceACLUsers
|
||
|
Instance:CreateInstanceACLUser
|
||
|
Instance:DeleteInstanceACLUser
|
||
|
Topic:ListTopics
|
||
|
Topic:CreateTopic
|
||
|
Topic:GetTopic
|
||
|
Topic:DeleteTopic
|
||
|
Topic:UpdateTopic
|
||
|
Topic:CreateMessage
|
||
|
ConsumerGroup:ListConsumerGroups
|
||
|
ConsumerGroup:CreateConsumerGroup
|
||
|
ConsumerGroup:GetConsumerGroup
|
||
|
ConsumerGroup:UpdateConsumerGroup
|
||
|
ConsumerGroup:DeleteConsumerGroup
|
||
|
Integration:ListIntegrations
|
||
|
Integration:CreateIntegration
|
||
|
Integration:GetIntegration
|
||
|
Integration:UpdateIntegration
|
||
|
Integration:DeleteIntegration
|
||
|
Integration:ListIntegrationTypes
|
||
|
Migration:CreateMigration
|
||
|
Migration:UpdateMigration
|
||
|
Migration:ListMigrations
|
||
|
Migration:GetMigration
|
||
|
Migration:DeleteMigration
|
||
|
Profile:ListDeployProfiles
|
||
|
Profile:GetDeployProfile
|
||
|
Profile:CreateDeployProfile
|
||
|
Profile:UpdateDeployProfile
|
||
|
Profile:DeleteDeployProfile
|
||
|
Environment:CreateProductVersion
|
||
|
Environment:GetDeploymentOrder
|
||
|
Environment:ListProductVersions
|
||
|
Environment:ListProviders
|
||
|
Environment:ListRegions
|
||
|
Environment:ListZones
|
||
|
Environment:ListSubnets
|
||
|
Environment:ListNodeGroups
|
||
|
Environment:GetNodeGroup
|
||
|
Environment:GetMessage
|
||
|
Environment:DeleteEndPoint
|
||
|
Environment:CreateEndPoint
|
||
|
KafkaLinking:CreateKafkaLink
|
||
|
KafkaLinking:ListKafkaLinks
|
||
|
KafkaLinking:GetKafkaLink
|
||
|
KafkaLinking:DeleteKafkaLink
|
||
|
EnvironmentAdmin
|
All
|
|
|
Source Cluster
|
Target Cluster
|
Migration Support
|
|---|---|---|
|
Apache Kafka
|
AutoMQ
|
Support
|
|
AWS MSK
|
Support
|
|
|
Confluent Platform
|
Supported
|
|
|
Alibaba Cloud Kafka
|
Supported
|
|
Parameter Items
|
**Limit Value**
|
**Description**
|
|---|---|---|
|
Instance Name
|
|
Names and notes should preferably use simple, common phrases and abbreviations. Avoid using special characters that may cause display issues.
|
|
Instance Description
|
|
|
|
Environment Member Name
|
|
|
|
Environment Member Password
|
|
|
Parameter Items
|
**Limit Value**
|
**Description**
|
|---|---|---|
|
log.retention.ms
Message Retention Period |
|
The message retention period affects storage space consumption and cost. It is advisable for businesses to assess this carefully. If unsatisfactory, please
Obtaining Services▸
Seek assistance.
|
|
message.max.bytes
Maximum message size |
|
If the current parameter limit does not meet your needs, please
Obtaining Services▸
seek assistance.
|
|
offsets.retention.minutes
Consumption Progress Retention Duration |
|
|
|
fetch.max.bytes
Single Data Fetch Limit |
|
|
|
Single partition write throughput limit
|
|
There are limitations on single partition read/write throughput. It is recommended that applications use different message keys to distribute the read/write load across different partitions to avoid partition hotspots. Please
Obtaining Services▸
Seeking Assistance.
|
|
Single Partition Read Throughput Limit
|
|
|
|
auto.create.topics.enable
Auto-create Topic Switch |
|
It is recommended to disable the automatic creation of topics and instead manage all topics through the control system and Admin API to prevent them from becoming unmanageable.
|
|
num.partitions
Default number of partitions for created topics |
|
The default number of partitions to create for a topic when using automatic topic creation should be set reasonably at the cluster level to avoid consuming too many of the partition quota with automatically created topics.
|
|
automq.zone.cidr.blocks
Client source CIDR availability zone identification |
|
The server matches the CIDR set in the current rule with the client's source IP to determine the client's corresponding availability zone. This configuration is used to optimize and eliminate cross-availability zone traffic for clients. The format specification for CIDR is \{zoneId}@\{cidr}\<>\{zoneId}@\{cidr}. Different availability zones are separated by "\<>", while multiple CIDR segments under the same availability zone are separated by ",".
Example:
|
|
Parameter Items
|
**Limit Value**
|
**Description**
|
|---|---|---|
|
compression.type
|
|
Set the final compression type for the Topic. This configuration supports ('gzip', 'snappy', 'lz4', 'zstd'); in addition to these options, it also supports 'uncompressed', meaning no compression is applied. The 'producer' configuration value refers to retaining the compression type set by the producer.
|
|
cleanup.policy
Message cleanup policy |
|
In most business scenarios, it is recommended to use the delete type, and only use the compact type in scenarios where preserving state data is required.
|
|
retention.ms
|
|
Configure a custom retention period for messages in a topic, applicable only to topics with a deletion clean-up policy. This configuration will override the default cluster settings.
|
|
max.message.bytes
|
|
Set the maximum allowable record batch size for the current topic, and any messages exceeding this limit will be rejected.
|
|
message.timestamp.type
|
|
Define whether the timestamp in the message corresponds to the message's creation time or the log append time. This value should be either 'create time' or 'log append time'.
|
|
retention.bytes
|
|
This setting applies to topics with a delete cleanup policy and controls the maximum retention space for each partition. By default, there is no size limit, only a time limit. This restriction is at the partition level, so multiply it by the number of partitions to compute the topic-level retention space. This configuration overrides the cluster's default settings.
|
|
delete.retention.ms
|
|
Set the retention time for deletion tombstones for Compact-type Topics, applicable only to Compact-type Topics. This configuration requires consumers to read messages within this timeframe to obtain the last valid snapshot; otherwise, they may read incomplete data.
|
|
Topic Naming
|
|
None.
|
|
Topic Notes
|
|
|
**Limit Item**
|
**Limit Value**
|
**Description**
|
|---|---|---|
|
Total number of product instances allowed within a single environment
|
Refer to subscription plan version constraints
|
If current constraints are not met, seek help through a support ticket.
Obtaining Services▸
.
|
|
Number of member accounts in a single environment:
|
100
|
|
**Limit Item**
|
**Limit Value**
|
**Description**
|
|---|---|---|
|
Single Instance (Cluster) Computing Specification
|
3AKU to 500AKU, offering the following capabilities:
|
The instance's compute specification denotes the maximum throughput capacity for sending and receiving messages on a single instance (cluster).
If there's a need for larger-scale clusters, please Obtaining Services▸ apply to raise the specification limits. |
|
Limits on the Number of Topics per Instance
|
Defined by the compute specifications of the instance; see specification limits for further details.
Billing Instructions for BYOC▸
.
|
For security and stability purposes, it's advisable to separate different business operations into distinct instances to avoid consolidating all operations into one instance.
|
|
Maximum Number of Partitions per Single Instance (Cluster)
|
||
|
Maximum Request QPS per Single Instance (Cluster)
|
|
Capabilities Provided by 1 AKU
|
Description
|
|
|---|---|---|
|
Read/Write Throughput
|
Write 30 MiB/s or Read 60 MiB/s
|
Core performance metrics and load for message read/write calls. If the predefined specifications are exceeded, it may result in slower service response times, increased RT, or rate-limiting failures.
*Example: For a specific AutoMQ instance, the write throughput is 60 MiB/s and the read throughput is 240 MiB/s. This instance's write throughput consumes 60/30 = 2 AKU, read throughput consumes 240/60 = 6 AKU, totaling 8 AKU.* |
|
Client Request Rate
|
800 requests per second
|
The application interacts with the server using the Kafka Producer and Consumer SDK, managing request rate and load. If the rate surpasses the predefined specifications, it may lead to throttling or longer response times (RT).
Request types include:
|
|
Upper limit on partition count
|
1125 pieces
|
The number of partitions limits the amount of metadata an instance can handle simultaneously. Exceeding the specified limit may result in the following situations:
AutoMQ, using an S3-based shared storage architecture, compared to Apache Kafka at the same cluster scale, supports 10 times Partition performance, without concerns about performance degradation due to an excessive number of partitions. If the default number of partitions is insufficient for your requirements, please Obtaining Services▸ contact us. |
|
Migration Stage
|
Rollback Plan
|
Rollback Impact
|
|---|---|---|
|
Step 1: Create Task
|
|
At this stage, since the application has not yet switched, there is no impact on the application
|
|
Step 2: Monitor Synchronization Progress
|
||
|
Step 3: Stop Source Cluster Consumers
|
|
Data remains unaffected, only causing consumption pauses and delays
|
|
Step 4: The consumer has been switched to the target cluster
|
|
Rolling back to the source cluster will reconsume data during the switching period
|
|
Step 5: The source cluster producer has been stopped
|
|
|
|
Step 6: The producer has been switched to the target cluster
|
|
During Step 6, messages produced to the target cluster cannot be reverse-synchronized back to the source cluster and require application processing.
|
|
In Step 7, the migration task has been deleted.
|
|
Not applicable
|
Comprehensive guides for AutoMQ - the S3-native diskless Kafka® with 10x cost savings and serverless scaling
Install AutoMQ from the AWS Marketplace.
Deploy AutoMQ on AWS EKS, Azure AKS, or Google Cloud GKE.
Understand the subscription and billing model for AutoMQ BYOC.
Integrate with data lakes like Iceberg for powerful analytics.
Seamlessly migrate from Apache Kafka to AutoMQ with zero downtime using Kafka-Linking.
Set up comprehensive monitoring and alerting with Prometheus.
Deploy a multi-node test cluster in minutes using Docker.
Deploy and manage AutoMQ clusters on Kubernetes with Helm.
Compare AutoMQ vs. Apache Kafka performance and see the 10x cost savings.
Understand the key architectural differences and advantages over Kafka.
Dive into the S3-native, shared storage architecture of AutoMQ.
Configure brokers, controllers, and object storage for optimal performance.
Choose your deployment option and start building with AutoMQ today. From local development to enterprise-scale production.
|
Resource Type
|
Operation Group
|
Included Operations
|
Recommended Scenarios
|
|---|---|---|---|
|
Cluster
|
All
|
|