Skip to content

KAFKA-20158: Parameterize session store unit tests to run with headers-aware store format #21749

Open
bbejeck wants to merge 26 commits intoapache:trunkfrom
bbejeck:KAFKA-20158_dsl_support_session_cogrouping
Open

KAFKA-20158: Parameterize session store unit tests to run with headers-aware store format #21749
bbejeck wants to merge 26 commits intoapache:trunkfrom
bbejeck:KAFKA-20158_dsl_support_session_cogrouping

Conversation

@bbejeck
Copy link
Member

@bbejeck bbejeck commented Mar 13, 2026

Add headers-enabled variants to SessionWindowedKStreamImplTest and
SessionWindowedCogroupedKStreamImplTest to verify session windowed
aggregations work correctly with the DSL_STORE_FORMAT_HEADERS config.

  • Convert aggregate, reduce, count, and materialize tests in
    SessionWindowedKStreamImplTest from @EnumSource to @MethodSource
    to test all combinations of emit strategy and headers mode

  • Convert aggregate tests in SessionWindowedCogroupedKStreamImplTest
    from @Test to @ParameterizedTest with @ValueSource(booleans)
    for headers toggling

@bbejeck bbejeck changed the title KAFKA:20158: Parameterize session store unit tests to run with headers-aware store format KAFKA-20158: Parameterize session store unit tests to run with headers-aware store format Mar 13, 2026
@mjsax mjsax added tests Test fixes (including flaky tests) kip Requires or implements a KIP labels Mar 14, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

kip Requires or implements a KIP streams tests Test fixes (including flaky tests)

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants