You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ja...@apache.org on 2026/09/22 13:08:58 UTC

(beam) 01/01: Merge pull request #40186: Kafka Streams runner: target flush markers across repartition topics

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ý <je...@seznam.cz>
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(-)