(kafka) branch trunk updated: MINOR: Reduce duplicate parameter combinations in heavy Streams integration tests (#22125)

[frankvicky]

This is an automated email from the ASF dual-hosted git repository.

frankvicky pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 76dcd5f41d7 MINOR: Reduce duplicate parameter combinations in heavy 
Streams integration tests (#22125)
76dcd5f41d7 is described below

commit 76dcd5f41d7a6f07ba93e1a61e3ea7b72119faa7
Author: Alieh Saeedi <107070585+aliehsaee...@users.noreply.github.com>
AuthorDate: Mon Apr 27 13:39:13 2026 +0200

    MINOR: Reduce duplicate parameter combinations in heavy Streams integration 
tests (#22125)
    
    Cuts redundant parameterized cases from three slow Streams integration
    tests without losing meaningful coverage:
    
      - IQv2StoreIntegrationTest — skips withHeaders=true rows for kind=PAPI
    and for global stores. DSL_STORE_FORMAT_CONFIG (the setting withHeaders
    toggles) only affects DSL stores built without an explicit supplier,  so
    those rows are exact duplicates of the withHeaders=false runs.
    
    Reviewers: TengYao Chi <frankvi...@apache.org>, Bill Bejeck
    <b...@confluent.io>
---
 .../apache/kafka/streams/integration/IQv2StoreIntegrationTest.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java
 
b/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java
index 2c4307bba44..be94882885a 100644
--- 
a/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java
+++ 
b/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java
@@ -364,6 +364,11 @@ public class IQv2StoreIntegrationTest {
                     for (final String kind : Arrays.asList("DSL", "PAPI")) {
                         for (final String groupProtocol : 
Arrays.asList("classic", "streams")) {
                             for (final boolean withHeaders : 
Arrays.asList(true, false)) {
+                                // DSL_STORE_FORMAT_CONFIG only affects DSL 
stores built without an
+                                // explicit supplier; for PAPI and global 
stores it is a no-op, so
+                                // skip the redundant withHeaders=true 
duplicates.
+                                if (withHeaders && (!"DSL".equals(kind) || 
toTest.global()))
+                                    continue;
                                 values.add(Arguments.of(cacheEnabled, 
logEnabled, toTest.name(), kind, groupProtocol, withHeaders));
                             }
                         }