unknowntpo opened a new pull request, #22952:
URL: https://github.com/apache/kafka/pull/22952
## Summary
- Configure the embedded broker used by `IQv2StoreIntegrationTest` with
`group.streams.initial.rebalance.delay.ms=0`.
- Preserve the complete 280-case store, API, cache, logging, headers, and
group-protocol matrix.
## Motivation
Each parameterized case creates one Kafka Streams client with a unique
application ID. The suite tests IQv2 store and query behavior, not multi-member
startup or rebalance timing, so the broker's production-oriented initial
rebalance delay only adds idle time before the first assignment.
Local JDK 21 measurements:
| Run | JUnit suite time | Initial-delay warnings |
| --- | ---: | ---: |
| Baseline | 953.808s | 216 |
| Modified | 679.107s | 0 |
| Modified rerun | 668.169s | 0 |
The two modified runs were 28.8% and 30.0% faster. Both exercised and passed
all 280 cases.
The setting is scoped to this test's embedded broker. Assignment,
processing, IQv2 polling, query results, and position assertions continue to
run unchanged. The classic group protocol is unaffected.
## Testing
```text
./gradlew :streams:integration-tests:test \
--tests org.apache.kafka.streams.integration.IQv2StoreIntegrationTest \
--rerun -PmaxParallelForks=1
```
Final validation on the latest `upstream/trunk`: 280 tests passed, 0
failures, 0 errors, 678.436s, and 0 initial-delay warnings.
Generated with GPT-5.6.
--
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]
