Eric Chang created KAFKA-20838:
----------------------------------

             Summary: 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


IQv2StoreIntegrationTest has 280 parameterized cases and currently takes about 
918 seconds (~15m19s) in CI.

Measurements show that the 108 non-global cases using the Streams group 
protocol take ~698.6s, while their matched classic-protocol cases take ~154.0s. 
Logs repeatedly report:

{code}
Assignment delayed due to the configured initial rebalance delay.
{code}

Each parameterized case starts a single client with a unique application.id. 
This test validates IQv2 store/query behavior; it does not test cold-start or 
rebalance timing.

Proposed change:
* Configure the embedded broker for this test with 
group.streams.initial.rebalance.delay.ms=0.
* Preserve the full parameter matrix.
* A/B benchmark the class and rerun the relevant integration tests to validate 
behavior.

Related, non-duplicate work: KAFKA-13714, KAFKA-15569, KAFKA-19705, and PR 
#22125.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to