This is an automated email from the ASF dual-hosted git repository.
schofielaj pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new b4b73c604b7 KAFKA-19245: Updated default locks config for share group
(#19705)
b4b73c604b7 is described below
commit b4b73c604b75db8b703da25fdb198ef3ee2d896f
Author: Apoorv Mittal <[email protected]>
AuthorDate: Tue May 13 13:46:25 2025 +0100
KAFKA-19245: Updated default locks config for share group (#19705)
Updated default locks config for share groups from 200 to 2000. The
increase in the limit is a result from tests which showed that with
default maxFetchRecords of 500 from client and 200 as locks limit, there
can't be parallel fetch for same partition. Also the tests resulted that
sharing a partition to an index of 3-4 is easily achievable, hence
raised the limit to 4 times of default limit of maxFetchRecords (500).
Reviewers: Andrew Schofield <[email protected]>
---
.../apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java
b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java
index faa9b92dff6..45e174d1a59 100644
---
a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java
+++
b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java
@@ -40,7 +40,7 @@ public class ShareGroupConfig {
public static final String SHARE_GROUP_ENABLE_DOC = "Enable share groups
on the broker.";
public static final String SHARE_GROUP_PARTITION_MAX_RECORD_LOCKS_CONFIG =
"group.share.partition.max.record.locks";
- public static final int SHARE_GROUP_PARTITION_MAX_RECORD_LOCKS_DEFAULT =
200;
+ public static final int SHARE_GROUP_PARTITION_MAX_RECORD_LOCKS_DEFAULT =
2000;
public static final String SHARE_GROUP_PARTITION_MAX_RECORD_LOCKS_DOC =
"Share-group record lock limit per share-partition.";
public static final String SHARE_GROUP_DELIVERY_COUNT_LIMIT_CONFIG =
"group.share.delivery.count.limit";
