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 07c1a1350b81dc02b2749a5e832ede6ed70d40e1 Merge: 790468a6591 60205a1a12a Author: Jan Lukavský <[email protected]> AuthorDate: Mon Sep 14 14:05:54 2026 +0200 Merge pull request #40068: Kafka Streams runner: add a flush marker payload variant .../src/main/proto/kafka_streams_payload.proto | 12 +++- .../kafka/streams/translation/FlushPayload.java | 37 +++++++++++ .../kafka/streams/translation/KStreamsPayload.java | 73 +++++++++++++++++++--- .../streams/translation/KStreamsPayloadSerde.java | 14 ++++- .../translation/KStreamsPayloadSerdeTest.java | 28 +++++++++ 5 files changed, 151 insertions(+), 13 deletions(-)
