chickenchickenlove opened a new pull request, #21317: URL: https://github.com/apache/kafka/pull/21317
### Description This test was flaky because it assumes the Streams group will reach `GroupState.NOT_READY`, but depending on timing and environment the Streams changelog topic could be created successfully. When that happened, the group progressed to `ASSIGNING/RECONCILING/STABLE`, the test failed to observe `NOT_READY` within the timeout, and it sometimes produced Reconciliation failed logs during consumer shutdown due to an unfinished onTasksAssigned-related event. This change makes the behavior deterministic by allowing `createStreamsGroup()` to inject a `replication factor` into `StreamsRebalanceData.TopicInfo`. In `testDescribeStreamsGroupsNotReady`, we pass an intentionally impossible replication factor for the current cluster (e.g., 9999), ensuring the changelog topic creation attempt always fails. As a result, the internal topic remains missing and the Streams group reliably stays in `NOT_READY`, eliminating the timing-dependent state transition that caused the flakiness. ### Result - Fixes https://develocity.apache.org/scans/tests?search.rootProjectNames=kafka&search.timeZoneId=Asia%2FTaipei&tests.container=kafka.api.PlaintextAdminIntegrationTest&tests.sortField=FLAKY&tests.test=testDescribeStreamsGroupsNotReady() -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
