This is an automated email from the ASF dual-hosted git repository.
je-ik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 790468a6591 Ensure 0 backlog is sent when finishing processing
restrictions. (#40102)
add a0adae53810 Kafka Streams runner: add a flush marker payload variant
add 60205a1a12a Carry target partitions in the flush marker, and shorten
the comments
new 07c1a1350b8 Merge pull request #40068: Kafka Streams runner: add a
flush marker payload variant
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../src/main/proto/kafka_streams_payload.proto | 12 +++-
.../{package-info.java => FlushPayload.java} | 21 ++++++-
.../kafka/streams/translation/KStreamsPayload.java | 73 +++++++++++++++++++---
.../streams/translation/KStreamsPayloadSerde.java | 14 ++++-
.../translation/KStreamsPayloadSerdeTest.java | 28 +++++++++
5 files changed, 133 insertions(+), 15 deletions(-)
copy
runners/kafka-streams/src/main/java/org/apache/beam/runners/kafka/streams/translation/{package-info.java
=> FlushPayload.java} (55%)
