[
https://issues.apache.org/jira/browse/KAFKA-20838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ken Huang resolved KAFKA-20838.
-------------------------------
Resolution: Fixed
> Reduce IQv2StoreIntegrationTest runtime by disabling test-only Streams
> initial rebalance delay
> ----------------------------------------------------------------------------------------------
>
> Key: KAFKA-20838
> URL: https://issues.apache.org/jira/browse/KAFKA-20838
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: Eric Chang
> Assignee: Eric Chang
> Priority: Major
>
> IQv2StoreIntegrationTest has 280 parameterized cases and takes about 918
> seconds (~15m19s) in CI. Logs repeatedly report:
> {code}
> Assignment delayed due to the configured initial rebalance delay.
> {code}
> Each invocation starts exactly one KafkaStreams instance with
> num.stream.threads=1. It does not add stream threads or start another
> instance with the same application.id, and every invocation uses a distinct
> application.id. Restore and global consumers are not application-group
> members. Therefore, each affected Streams group has one member.
> The suite covers stores, DSL/PAPI, caching, logging, headers, and both group
> protocols. It validates IQv2 store/query behavior, not initial group
> formation, so the delay only adds idle time.
> h3. Proposed change
> * Set group.streams.initial.rebalance.delay.ms=0 on this test's embedded
> broker.
> * Preserve the full 280-case matrix.
> h3. Local JDK 21 results
> * Baseline: 953.808s; 280 passed; 216 delay warnings.
> * Modified: 679.107s; 280 passed; no delay warnings; 28.8% faster.
> * Modified rerun: 668.169s; 280 passed; no delay warnings; 30.0% faster.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
