This is an automated email from the ASF dual-hosted git repository.
mimaison 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 21805d928f8 MINOR: Fix typos in GroupMetadataManagerTest comments
(#22773)
21805d928f8 is described below
commit 21805d928f8cebbaefa06aca5bd9f4307c548378
Author: Diya Hussein <[email protected]>
AuthorDate: Thu Jul 9 16:12:18 2026 +0300
MINOR: Fix typos in GroupMetadataManagerTest comments (#22773)
Trivial comment typo fix: `inital` -> `initial` in 7 occurrences across
GroupMetadataManagerTest.java.
Reviewers: Mickael Maison <[email protected]>
---
.../kafka/coordinator/group/GroupMetadataManagerTest.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git
a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java
b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java
index f3568dc089b..cb9f7bd5fc2 100644
---
a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java
+++
b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java
@@ -6133,10 +6133,10 @@ public class GroupMetadataManagerTest {
requiredKnownMemberId
)).toList();
- // Advance clock by group initial rebalance delay to complete first
inital delayed join.
+ // Advance clock by group initial rebalance delay to complete first
initial delayed join.
// This will extend the initial rebalance as new members have joined.
GroupMetadataManagerTestContext.assertNoOrEmptyResult(context.sleep(50));
- // Advance clock by group initial rebalance delay to complete second
inital delayed join.
+ // Advance clock by group initial rebalance delay to complete second
initial delayed join.
// Since there are no new members that joined since the previous
delayed join,
// the join group phase will complete.
GroupMetadataManagerTestContext.assertNoOrEmptyResult(context.sleep(50));
@@ -6182,10 +6182,10 @@ public class GroupMetadataManagerTest {
assertEquals(groupMaxSize, group.numAwaitingJoinResponse());
assertTrue(group.isInState(PREPARING_REBALANCE));
- // Advance clock by group initial rebalance delay to complete first
inital delayed join.
+ // Advance clock by group initial rebalance delay to complete first
initial delayed join.
// This will extend the initial rebalance as new members have joined.
GroupMetadataManagerTestContext.assertNoOrEmptyResult(context.sleep(50));
- // Advance clock by group initial rebalance delay to complete second
inital delayed join.
+ // Advance clock by group initial rebalance delay to complete second
initial delayed join.
// Since there are no new members that joined since the previous
delayed join,
// we will complete the rebalance.
GroupMetadataManagerTestContext.assertNoOrEmptyResult(context.sleep(50));
@@ -6237,7 +6237,7 @@ public class GroupMetadataManagerTest {
// Advance clock by group initial rebalance delay to complete first
initial delayed join.
// This will extend the initial rebalance as new members have joined.
GroupMetadataManagerTestContext.assertNoOrEmptyResult(context.sleep(50));
- // Advance clock by group initial rebalance delay to complete second
inital delayed join.
+ // Advance clock by group initial rebalance delay to complete second
initial delayed join.
// Since there are no new members that joined since the previous
delayed join,
// we will complete the rebalance.
GroupMetadataManagerTestContext.assertNoOrEmptyResult(context.sleep(50));
@@ -6307,10 +6307,10 @@ public class GroupMetadataManagerTest {
requiredKnownMemberId
)).toList();
- // Advance clock by group initial rebalance delay to complete first
inital delayed join.
+ // Advance clock by group initial rebalance delay to complete first
initial delayed join.
// This will extend the initial rebalance as new members have joined.
GroupMetadataManagerTestContext.assertNoOrEmptyResult(context.sleep(50));
- // Advance clock by group initial rebalance delay to complete second
inital delayed join.
+ // Advance clock by group initial rebalance delay to complete second
initial delayed join.
// Since there are no new members that joined since the previous
delayed join,
// we will complete the rebalance.
GroupMetadataManagerTestContext.assertNoOrEmptyResult(context.sleep(50));