You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by li...@apache.org on 2025/01/14 20:37:58 UTC
(kafka) branch 4.0 updated: MINOR: Improve doc for config group.consumer.max.size (#18533)
This is an automated email from the ASF dual-hosted git repository.
lianetm pushed a commit to branch 4.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/4.0 by this push:
new 4be1376290e MINOR: Improve doc for config group.consumer.max.size (#18533)
4be1376290e is described below
commit 4be1376290e126a9eaff1cfd7afcc91a9c9e1fbc
Author: Lianet Magrans <98...@users.noreply.github.com>
AuthorDate: Tue Jan 14 21:36:14 2025 +0100
MINOR: Improve doc for config group.consumer.max.size (#18533)
Reviewers: David Jacot <da...@gmail.com>
---
.../org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java
index f1ae15cbc7a..804d80b2266 100644
--- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java
+++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java
@@ -114,7 +114,10 @@ public class GroupCoordinatorConfig {
public static final int CONSUMER_GROUP_MAX_HEARTBEAT_INTERVAL_MS_DEFAULT = 15000;
public static final String CONSUMER_GROUP_MAX_SIZE_CONFIG = "group.consumer.max.size";
- public static final String CONSUMER_GROUP_MAX_SIZE_DOC = "The maximum number of consumers that a single consumer group can accommodate. This value will only impact the new consumer coordinator. To configure the classic consumer coordinator check " + GROUP_MAX_SIZE_CONFIG + " instead.";
+ public static final String CONSUMER_GROUP_MAX_SIZE_DOC = "The maximum number of consumers " +
+ "that a single consumer group can accommodate. This value will only impact groups under " +
+ "the CONSUMER group protocol. To configure the max group size when using the CLASSIC " +
+ "group protocol use " + GROUP_MAX_SIZE_CONFIG + " " + "instead.";
public static final int CONSUMER_GROUP_MAX_SIZE_DEFAULT = Integer.MAX_VALUE;
public static final String CONSUMER_GROUP_ASSIGNORS_CONFIG = "group.consumer.assignors";