You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "mingyen066 (via GitHub)" <gi...@apache.org> on 2026/03/08 15:29:23 UTC
[PR] KAFKA-20160: Group configuration for share.partition.max.record.locks [kafka]
mingyen066 opened a new pull request, #21678:
URL: https://github.com/apache/kafka/pull/21678
Add group-level dynamic config `share.partition.max.record.locks` (KIP-1240) to control the maximum number of record locks per share-partition, with broker-level min/max bounds validation.
Also extract config lookup helpers into `ShareGroupConfigProvider`, aligning with the approach in #21467.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-20160: Group configuration for share.partition.max.record.locks [kafka]
Posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org>.
AndrewJSchofield commented on PR #21678:
URL: https://github.com/apache/kafka/pull/21678#issuecomment-4025529171
When https://github.com/apache/kafka/pull/21691 merges, please merge latest changes from trunk.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-20160: Group configuration for share.partition.max.record.locks [kafka]
Posted by "mingyen066 (via GitHub)" <gi...@apache.org>.
mingyen066 commented on code in PR #21678:
URL: https://github.com/apache/kafka/pull/21678#discussion_r2906252032
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfig.java:
##########
Review Comment:
Sure.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-20160: Group configuration for share.partition.max.record.locks [kafka]
Posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org>.
AndrewJSchofield merged PR #21678:
URL: https://github.com/apache/kafka/pull/21678
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-20160: Group configuration for share.partition.max.record.locks [kafka]
Posted by "mingyen066 (via GitHub)" <gi...@apache.org>.
mingyen066 commented on code in PR #21678:
URL: https://github.com/apache/kafka/pull/21678#discussion_r2906319976
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java:
##########
@@ -43,6 +43,14 @@ public class ShareGroupConfig {
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_MAX_PARTITION_MAX_RECORD_LOCKS_CONFIG = "group.share.max.partition.max.record.locks";
+ public static final int SHARE_GROUP_MAX_PARTITION_MAX_RECORD_LOCKS_DEFAULT = 10000;
Review Comment:
Fixed, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-20160: Group configuration for share.partition.max.record.locks [kafka]
Posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org>.
AndrewJSchofield commented on PR #21678:
URL: https://github.com/apache/kafka/pull/21678#issuecomment-4024012203
Failing test `SharePartitionTest > testRenewAcknowledgeDisabledWithPerOffsetAck()`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-20160: Group configuration for share.partition.max.record.locks [kafka]
Posted by "mingyen066 (via GitHub)" <gi...@apache.org>.
mingyen066 commented on PR #21678:
URL: https://github.com/apache/kafka/pull/21678#issuecomment-4024774880
Failed `GroupMetadataManagerTest` seems unrelated
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-20160: Group configuration for share.partition.max.record.locks [kafka]
Posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org>.
AndrewJSchofield commented on code in PR #21678:
URL: https://github.com/apache/kafka/pull/21678#discussion_r2905295645
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfig.java:
##########
Review Comment:
I know this is adjacent code and not strictly part of this PR, but please could you put the missing javadoc on this method. Thanks.
##########
core/src/test/java/kafka/server/share/SharePartitionTest.java:
##########
@@ -12427,6 +12427,183 @@ public void testDynamicDeliveryCountIncreaseAllowsMoreDeliveries() {
assertFalse(sharePartition.cachedState().isEmpty());
}
+ @Test
+ public void testMaxInFlightRecordsUsesGroupConfigWhenPresent() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ GroupConfig groupConfig = Mockito.mock(GroupConfig.class);
+ when(groupConfig.sharePartitionMaxRecordLocks()).thenReturn(5000);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.of(groupConfig));
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(2000)
+ .withGroupConfigManager(groupConfigManager)
+ .withState(SharePartitionState.ACTIVE)
+ .build();
+
+ // maxInFlightRecords() should return the group config value, not the default.
+ assertEquals(5000, sharePartition.maxInFlightRecords());
+ }
+
+ @Test
+ public void testMaxInFlightRecordsFallsBackToDefaultWhenNoGroupConfig() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.empty());
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(2000)
+ .withGroupConfigManager(groupConfigManager)
+ .withState(SharePartitionState.ACTIVE)
+ .build();
+
+ // maxInFlightRecords() should return the default value.
+ assertEquals(2000, sharePartition.maxInFlightRecords());
+ }
+
+ @Test
+ public void testDynamicPartitionMaxRecordLocksDecrease() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.empty());
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(100)
+ .withGroupConfigManager(groupConfigManager)
+ .withState(SharePartitionState.ACTIVE)
+ .build();
+
+ MemoryRecords records = memoryRecords(0, 50);
+
+ // Acquire 50 records, which is under the default limit of 100.
+ fetchAcquiredRecords(sharePartition, records, 50);
+
+ // Dynamically decrease the limit to 30 via group config.
+ GroupConfig groupConfig = Mockito.mock(GroupConfig.class);
+ when(groupConfig.sharePartitionMaxRecordLocks()).thenReturn(30);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.of(groupConfig));
+
+ // The effective limit should now be 30.
+ assertEquals(30, sharePartition.maxInFlightRecords());
+
+ // 50 in-flight > 30 limit, but canAcquireRecords checks nextFetchOffset != endOffset + 1
+ // first. Since all records [0-49] are acquired, nextFetchOffset == endOffset + 1 == 50,
+ // so the second check (numInFlightRecords < maxInFlightRecords) applies: 50 < 30 is false.
+ assertFalse(sharePartition.canAcquireRecords());
+ }
+
+ @Test
+ public void testDynamicPartitionMaxRecordLocksIncrease() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.empty());
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(10)
+ .withGroupConfigManager(groupConfigManager)
+ .withState(SharePartitionState.ACTIVE)
+ .build();
+
+ MemoryRecords records = memoryRecords(0, 10);
+
+ // Acquire 10 records, hitting the default limit.
+ fetchAcquiredRecords(sharePartition, records, 10);
+
+ // canAcquireRecords should be false with default limit of 10.
+ assertFalse(sharePartition.canAcquireRecords());
+
+ // Increase limit to 500 via group config.
+ GroupConfig groupConfig = Mockito.mock(GroupConfig.class);
+ when(groupConfig.sharePartitionMaxRecordLocks()).thenReturn(500);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.of(groupConfig));
+
+ assertEquals(500, sharePartition.maxInFlightRecords());
+
+ // Now canAcquireRecords should be true: 10 < 500.
+ assertTrue(sharePartition.canAcquireRecords());
+ }
+
+ @Test
+ public void testDynamicPartitionMaxRecordLocksExactBoundary() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.empty());
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(50)
+ .withGroupConfigManager(groupConfigManager)
+ .withState(SharePartitionState.ACTIVE)
+ .build();
+
+ MemoryRecords records = memoryRecords(0, 50);
+
+ // Acquire exactly 50 records, hitting the default limit exactly.
+ fetchAcquiredRecords(sharePartition, records, 50);
+
+ // At exact boundary: 50 < 50 is false.
+ assertFalse(sharePartition.canAcquireRecords());
+
+ // Dynamically set limit to exactly the in-flight count via group config.
+ GroupConfig groupConfig = Mockito.mock(GroupConfig.class);
+ when(groupConfig.sharePartitionMaxRecordLocks()).thenReturn(50);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.of(groupConfig));
+
+ // Still at boundary: 50 < 50 is false.
+ assertFalse(sharePartition.canAcquireRecords());
+
+ // Increase by 1 to cross the boundary.
+ when(groupConfig.sharePartitionMaxRecordLocks()).thenReturn(51);
+
+ // Now 50 < 51 is true.
+ assertTrue(sharePartition.canAcquireRecords());
+ }
+
+ @Test
+ public void testDynamicPartitionMaxRecordLocksRemoveGroupConfig() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ GroupConfig groupConfig = Mockito.mock(GroupConfig.class);
+ when(groupConfig.sharePartitionMaxRecordLocks()).thenReturn(500);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.of(groupConfig));
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(100)
+ .withGroupConfigManager(groupConfigManager)
+ .withState(SharePartitionState.ACTIVE)
+ .build();
+
+ // Group config sets limit to 500.
+ assertEquals(500, sharePartition.maxInFlightRecords());
+
+ // Remove group config — should fall back to default of 100.
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.empty());
+
+ assertEquals(100, sharePartition.maxInFlightRecords());
+ }
+
+ @Test
+ public void testDynamicPartitionMaxRecordLocksDecreaseBelowInFlightAffectsMaxRecordsToAcquire() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.empty());
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(100)
Review Comment:
This is really the default max in-flight records I think.
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java:
##########
@@ -43,6 +43,14 @@ public class ShareGroupConfig {
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_MAX_PARTITION_MAX_RECORD_LOCKS_CONFIG = "group.share.max.partition.max.record.locks";
+ public static final int SHARE_GROUP_MAX_PARTITION_MAX_RECORD_LOCKS_DEFAULT = 10000;
Review Comment:
The default for the maximum according to the KIP is 4000.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-20160: Group configuration for share.partition.max.record.locks [kafka]
Posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org>.
AndrewJSchofield commented on PR #21678:
URL: https://github.com/apache/kafka/pull/21678#issuecomment-4019778375
@mingyen066 Thanks for the PR. Looks like a check style failure in one of the test files.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-20160: Group configuration for share.partition.max.record.locks [kafka]
Posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org>.
AndrewJSchofield commented on PR #21678:
URL: https://github.com/apache/kafka/pull/21678#issuecomment-4020101873
@mingyen066 Please merge latest changes from trunk.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-20160: Group configuration for share.partition.max.record.locks [kafka]
Posted by "mingyen066 (via GitHub)" <gi...@apache.org>.
mingyen066 commented on PR #21678:
URL: https://github.com/apache/kafka/pull/21678#issuecomment-4019811645
Sorry, accidentally force-pushed. Only fixed import ordering.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] KAFKA-20160: Group configuration for share.partition.max.record.locks [kafka]
Posted by "mingyen066 (via GitHub)" <gi...@apache.org>.
mingyen066 commented on code in PR #21678:
URL: https://github.com/apache/kafka/pull/21678#discussion_r2906296387
##########
core/src/test/java/kafka/server/share/SharePartitionTest.java:
##########
@@ -12427,6 +12427,183 @@ public void testDynamicDeliveryCountIncreaseAllowsMoreDeliveries() {
assertFalse(sharePartition.cachedState().isEmpty());
}
+ @Test
+ public void testMaxInFlightRecordsUsesGroupConfigWhenPresent() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ GroupConfig groupConfig = Mockito.mock(GroupConfig.class);
+ when(groupConfig.sharePartitionMaxRecordLocks()).thenReturn(5000);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.of(groupConfig));
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(2000)
+ .withGroupConfigManager(groupConfigManager)
+ .withState(SharePartitionState.ACTIVE)
+ .build();
+
+ // maxInFlightRecords() should return the group config value, not the default.
+ assertEquals(5000, sharePartition.maxInFlightRecords());
+ }
+
+ @Test
+ public void testMaxInFlightRecordsFallsBackToDefaultWhenNoGroupConfig() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.empty());
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(2000)
+ .withGroupConfigManager(groupConfigManager)
+ .withState(SharePartitionState.ACTIVE)
+ .build();
+
+ // maxInFlightRecords() should return the default value.
+ assertEquals(2000, sharePartition.maxInFlightRecords());
+ }
+
+ @Test
+ public void testDynamicPartitionMaxRecordLocksDecrease() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.empty());
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(100)
+ .withGroupConfigManager(groupConfigManager)
+ .withState(SharePartitionState.ACTIVE)
+ .build();
+
+ MemoryRecords records = memoryRecords(0, 50);
+
+ // Acquire 50 records, which is under the default limit of 100.
+ fetchAcquiredRecords(sharePartition, records, 50);
+
+ // Dynamically decrease the limit to 30 via group config.
+ GroupConfig groupConfig = Mockito.mock(GroupConfig.class);
+ when(groupConfig.sharePartitionMaxRecordLocks()).thenReturn(30);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.of(groupConfig));
+
+ // The effective limit should now be 30.
+ assertEquals(30, sharePartition.maxInFlightRecords());
+
+ // 50 in-flight > 30 limit, but canAcquireRecords checks nextFetchOffset != endOffset + 1
+ // first. Since all records [0-49] are acquired, nextFetchOffset == endOffset + 1 == 50,
+ // so the second check (numInFlightRecords < maxInFlightRecords) applies: 50 < 30 is false.
+ assertFalse(sharePartition.canAcquireRecords());
+ }
+
+ @Test
+ public void testDynamicPartitionMaxRecordLocksIncrease() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.empty());
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(10)
+ .withGroupConfigManager(groupConfigManager)
+ .withState(SharePartitionState.ACTIVE)
+ .build();
+
+ MemoryRecords records = memoryRecords(0, 10);
+
+ // Acquire 10 records, hitting the default limit.
+ fetchAcquiredRecords(sharePartition, records, 10);
+
+ // canAcquireRecords should be false with default limit of 10.
+ assertFalse(sharePartition.canAcquireRecords());
+
+ // Increase limit to 500 via group config.
+ GroupConfig groupConfig = Mockito.mock(GroupConfig.class);
+ when(groupConfig.sharePartitionMaxRecordLocks()).thenReturn(500);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.of(groupConfig));
+
+ assertEquals(500, sharePartition.maxInFlightRecords());
+
+ // Now canAcquireRecords should be true: 10 < 500.
+ assertTrue(sharePartition.canAcquireRecords());
+ }
+
+ @Test
+ public void testDynamicPartitionMaxRecordLocksExactBoundary() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.empty());
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(50)
+ .withGroupConfigManager(groupConfigManager)
+ .withState(SharePartitionState.ACTIVE)
+ .build();
+
+ MemoryRecords records = memoryRecords(0, 50);
+
+ // Acquire exactly 50 records, hitting the default limit exactly.
+ fetchAcquiredRecords(sharePartition, records, 50);
+
+ // At exact boundary: 50 < 50 is false.
+ assertFalse(sharePartition.canAcquireRecords());
+
+ // Dynamically set limit to exactly the in-flight count via group config.
+ GroupConfig groupConfig = Mockito.mock(GroupConfig.class);
+ when(groupConfig.sharePartitionMaxRecordLocks()).thenReturn(50);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.of(groupConfig));
+
+ // Still at boundary: 50 < 50 is false.
+ assertFalse(sharePartition.canAcquireRecords());
+
+ // Increase by 1 to cross the boundary.
+ when(groupConfig.sharePartitionMaxRecordLocks()).thenReturn(51);
+
+ // Now 50 < 51 is true.
+ assertTrue(sharePartition.canAcquireRecords());
+ }
+
+ @Test
+ public void testDynamicPartitionMaxRecordLocksRemoveGroupConfig() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ GroupConfig groupConfig = Mockito.mock(GroupConfig.class);
+ when(groupConfig.sharePartitionMaxRecordLocks()).thenReturn(500);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.of(groupConfig));
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(100)
+ .withGroupConfigManager(groupConfigManager)
+ .withState(SharePartitionState.ACTIVE)
+ .build();
+
+ // Group config sets limit to 500.
+ assertEquals(500, sharePartition.maxInFlightRecords());
+
+ // Remove group config — should fall back to default of 100.
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.empty());
+
+ assertEquals(100, sharePartition.maxInFlightRecords());
+ }
+
+ @Test
+ public void testDynamicPartitionMaxRecordLocksDecreaseBelowInFlightAffectsMaxRecordsToAcquire() {
+ GroupConfigManager groupConfigManager = Mockito.mock(GroupConfigManager.class);
+ when(groupConfigManager.groupConfig(GROUP_ID)).thenReturn(Optional.empty());
+
+ SharePartition sharePartition = SharePartitionBuilder.builder()
+ .withMaxInflightRecords(100)
Review Comment:
Right, removed the explicit `withMaxInflightRecords()` call and renamed test constants/builder fields to align with `SharePartition` parameter names (e.g. `MAX_IN_FLIGHT_RECORDS` → `DEFAULT_MAX_IN_FLIGHT_RECORDS`, `MAX_DELIVERY_COUNT` → `DEFAULT_MAX_DELIVERY_COUNT`).
Also changed from short to int to match `sharePartitionMaxRecordLocks()` return type.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org