Creating a RocketMQ Consumer Group
A consumer group is a group of consumers with the same behavior and is used to manage and maintain message retrieval. A consumer can manage a type of messages using a consumer group.
At least one RocketMQ consumer group is automatically created.
Notes and Constraints
Consumer group names cannot be used across instances. For example, Group01 created in instance A cannot be used in instance B.
Prerequisites
A RocketMQ instance has been purchased.
Creating a RocketMQ Consumer Group
- Log in to the console.
- Click
in the upper left corner to select a region.
DMS for RocketMQ instances in different regions cannot communicate with each other over an intranet. Select a nearest location for low latency and fast access.
- Click
and choose Middleware > Distributed Message Service for RocketMQ to open the console of DMS for RocketMQ.
- Click a RocketMQ instance to go to the instance details page.
- In the navigation pane, choose Instance > Consumer Groups.
- Click Create Consumer Group.
- Configure the consumer group name and other parameters by referring to Table 1.
Table 1 Consumer group parameters Parameter
Description
Consumer Group Name
Name of the consumer group.
A consumer group must meet the following requirements:- Contains 3 to 64 characters.
- Contains only letters, digits, percent signs (%), vertical bars (|), hyphens (-), and underscores (_).
Once the consumer group is created, you cannot modify its name.
Brokers
This parameter is mandatory for a RocketMQ 4.8.0 instance.
Select one or multiple brokers to create consumer groups as required. The consumer groups are automatically created.
Once the consumer group is created, you cannot modify its brokers.
Maximum Retries
Maximum number of retry attempts allowed for normal messages.
Value range: 1–16
For ordered retrievals, this limit can be configured by using the setMaxReconsumeTimes method.
Broadcast
Indicates whether messages are broadcast.
If this option is enabled, each message is retrieved by all consumers in the consumer group. If this option is disabled, each message is retrieved by only one consumer in the consumer group.
Orderly
This parameter is mandatory for a RocketMQ 5.x instance.
If this option is enabled, consumers consume messages in sequence. Orderly consumption ensures sequential consumption by message sending. In this case, earlier messages are consumed before later messages
Description
Description of the consumer group.
0–200 characters
- Click OK.
When a consumer group is created, Consumer Group Status and Consumption Mode are displayed in the consumer group list (only for v4.8.0).
- Consumer Group Status can be Online or Offline.
- Consumption Mode can be:
- CLUSTERING: cluster consumption mode. RocketMQ consumes any message by any consumer in the consumer group.
- BROADCASTING: broadcast consumption mode. RocketMQ pushes each message to all consumers in the consumer group to ensure that the message is consumed by each consumer.
Consumption Mode is -- when the consumer group is offline.
Related Documents
- To create a consumer group by calling an API, see Creating a Consumer Group or Batch Deleting Consumer Groups.
- To create multiple users and assign different consumer group permissions to them for user-isolated permissions, enable ACL and configure users. For details, see Enabling RocketMQ ACL and Configuring RocketMQ ACL Users.
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.
For any further questions, feel free to contact us through the chatbot.
Chatbot