- Release Notes and Announcements
- Product Introduction
- Purchase Guide
- RocketMQ 5.x
- RocketMQ 4.x
- Product Introduction
- Purchase Guide
- Getting Started
- Operation Guide
- Development Guide
- SDK Documentation
- Migration to Cloud
- API Documentation
- FAQs
- TDMQ for RocketMQ Service Level Agreement
- Contact Us
- Release Notes and Announcements
- Product Introduction
- Purchase Guide
- RocketMQ 5.x
- RocketMQ 4.x
- Product Introduction
- Purchase Guide
- Getting Started
- Operation Guide
- Development Guide
- SDK Documentation
- Migration to Cloud
- API Documentation
- FAQs
- TDMQ for RocketMQ Service Level Agreement
- Contact Us
This document describes the features and use cases of clustering consumption and broadcasting consumption in TDMQ for RocketMQ.
Feature Overview
Cluster consumption: if the cluster consumption mode is used, any message only needs to be processed by any consumer in the cluster.
Broadcast consumption: if the broadcast consumption mode is used, each message will be pushed to all registered consumers in the cluster to ensure that the message is consumed by each consumer at least once.
Use Cases
Clustering consumption is suitable for scenarios where each message only needs to be processed once.
Broadcasting consumption is suitable for scenarios where each message needs to be processed by each consumer in the cluster.
Sample Codes
Cluster subscription
All consumers identified by the same group ID will evenly share messages for consumption. For example, if a topic has nine messages, and a group ID identifies three consumer instances, then each instance will consume only three messages evenly in the clustering consumption mode.
// Set the cluster subscription mode (which is the default mode if you don't specify one)properties.put(PropertyKeyConst.MessageModel, PropertyValueConst.CLUSTERING);
Broadcast subscription
A message will be consumed once by all consumers identified by the same group ID. In the broadcasting consumption mode, for example, if a topic has nine messages and a group ID identifies three consumer instances, each instance will consume nine messages.
// Set the broadcast subscription modeproperties.put(PropertyKeyConst.MessageModel, PropertyValueConst.BROADCASTING);
Note
You need to ensure that all consumer instances under the same group ID have the same subscription relationships.
Yes
No
Was this page helpful?