This is an automated email from the ASF dual-hosted git repository. je-ik pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 25dc1ba1da8064f0507eefd77c522f4e7409482d Merge: 7d0f1bf3870 e038146a76b Author: Jan Lukavský <[email protected]> AuthorDate: Tue Sep 22 15:08:48 2026 +0200 Merge pull request #40186: Kafka Streams runner: target flush markers across repartition topics .../streams/translation/GroupByKeyTranslator.java | 14 +- ...tioner.java => KStreamsPayloadPartitioner.java} | 25 ++- .../streams/translation/ShuffleByKeyProcessor.java | 35 +++- .../streams/translation/TerminationTracker.java | 4 +- .../KStreamsPayloadPartitionerBrokerIT.java | 176 +++++++++++++++++++++ .../KStreamsPayloadPartitionerTest.java | 74 +++++++++ .../translation/ShuffleByKeyProcessorTest.java | 75 ++++++++- 7 files changed, 389 insertions(+), 14 deletions(-)
