Skip to content

test(plugin-kafka): spread the group sweep over three coordinators instead of six - #3024

Merged
datlechin merged 1 commit into
mainfrom
test/kafka-group-sweep-cost
Sep 20, 2026
Merged

datlechin merged 1 commit into
mainfrom
test/kafka-group-sweep-cost

Conversation

@datlechin

Copy link
Copy Markdown
Member

Follow-up to #3023, which merged while this was still being verified.

showGroupsCoversEveryBroker committed offsets for six consumer groups, and each one runs a console consumer in its own container. On the run that caught this the test host was killed mid-case with Test crashed with signal term at 0.000 seconds, while the other 33 integration cases passed; the whole testing phase had taken 34.8 seconds. It is a cost problem, not an assertion problem.

Three groups is the fewest that can land on three coordinators, which is all the assertion needs: the test exists to prove SHOW GROUPS asks every broker rather than only the one the connection was opened to, and which broker coordinates a group is a hash of its id.

Verification

verify.sh test over the nine Kafka suites, against the three-broker cluster scripts/kafka-test-broker.sh up --brokers 3 starts:

cases: 152 executed, 152 passed, 0 failed

That is the run this commit was needed for. The same command on the previous commit reported 151 of 152 with the terminated case.

@datlechin
datlechin merged commit 7d9375b into main Sep 20, 2026
7 checks passed
@datlechin
datlechin deleted the test/kafka-group-sweep-cost branch September 20, 2026 15:15
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant