Skip to content

MINOR: Address suppress HEADERS system test follow-ups - #23269

Open
aliehsaeedii wants to merge 1 commit into
apache:trunkfrom
aliehsaeedii:KAFKA-20850-followups
Open

MINOR: Address suppress HEADERS system test follow-ups#23269
aliehsaeedii wants to merge 1 commit into
apache:trunkfrom
aliehsaeedii:KAFKA-20850-followups

Conversation

@aliehsaeedii

@aliehsaeedii aliehsaeedii commented Aug 25, 2026

Copy link
Copy Markdown
Contributor

Follow-ups from the review of #23075:

  • Warn against changing the "Restoring apparently invalid changelog
    record" exception message in InMemoryTimeOrderedKeyValueChangeBuffer,
    since streams_application_upgrade_test.py greps the logs for it to
    assert that no suppress-changelog record is rejected while restoring
    across the HEADERS format boundary.

  • Remove the dead "rolling" bounce path in
    streams_application_upgrade_test.py. No test ever set
    bounce_type="rolling" (the matrix has always been ["full"]), so the
    branch and its only caller, do_stop_start_bounce, were unreachable. Drop
    the now single-valued bounce_type parameter as well.

Reviewers: Matthias J. Sax matthias@confluent.io, Chia-Ping Tsai
chia7712@gmail.com

- Warn against changing the "Restoring apparently invalid changelog
  record" exception message in InMemoryTimeOrderedKeyValueChangeBuffer,
  since streams_application_upgrade_test.py greps the logs for it.
- Remove the dead "rolling" bounce path in the system test (no test
  ever set bounce_type="rolling"), along with its only caller
  do_stop_start_bounce and the now single-valued bounce_type parameter.
@aliehsaeedii
aliehsaeedii force-pushed the KAFKA-20850-followups branch from 2f946c6 to c063d92 Compare August 25, 2026 12:31

@mjsax mjsax left a comment

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I'll leave it to @chia7712 to merge and cherry-pick to 4.4 branch :D

@mjsax mjsax added tests Test fixes (including flaky tests) ci-approved and removed triage PRs from the community labels Aug 25, 2026

@chia7712 chia7712 left a comment

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

overall LGTM except for one small comment. The e2e test passes on my machine

SESSION REPORT (ALL TESTS)
ducktape version: 0.14.0
session_id:       2026-08-26--003
run time:         6 minutes 36.532 seconds
tests run:        21
passed:           21
flaky:            0
failed:           0
ignored:          0

@matrix(from_version=smoke_test_versions, metadata_quorum=[quorum.combined_kraft])
def test_app_upgrade(self, from_version, metadata_quorum):
"""
Starts 3 KafkaStreams instances with <old_version>, and upgrades one-by-one to <new_version>

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Would you mind updating the docstring? The one-by-one is obsolete

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

ci-approved small Small PRs streams tests Test fixes (including flaky tests)

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants