From 2ab9e850fa69de02b62c9da7d64a109f8b7d74a9 Mon Sep 17 00:00:00 2001 From: vongosling Date: Thu, 22 Aug 2019 14:19:14 +0800 Subject: [PATCH] Polish the consumer group doc --- .../rocketmq/client/consumer/DefaultLitePullConsumer.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java index 5a2189f3..99976d55 100644 --- a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java +++ b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java @@ -35,7 +35,12 @@ public class DefaultLitePullConsumer extends ClientConfig implements LitePullCon private final DefaultLitePullConsumerImpl defaultLitePullConsumerImpl; /** - * Do the same thing for the same Group, the application must be set,and guarantee Globally unique + * Consumers belonging to the same consumer group share a group id. The consumers in a group then + * divides the topic as fairly amongst themselves as possible by establishing that each queue is only + * consumed by a single consumer from the group. If all consumers are from the same group, it functions + * as a traditional message queue. Each message would be consumed by one consumer of the group only. + * When multiple consumer groups exist, the flow of the data consumption model aligns with the traditional + * publish-subscribe model. The messages are broadcast to all consumer groups. */ private String consumerGroup; -- GitLab