This is an automated email from the ASF dual-hosted git repository. vterentev pushed a commit to branch release-2.72 in repository https://gitbox.apache.org/repos/asf/beam.git
commit 1ab9316db130a3fb6bc68b9afea122ee48dd7087 Merge: 34dfa90a490 15ed9fba3c2 Author: Vitaly Terentyev <[email protected]> AuthorDate: Tue Feb 24 17:18:20 2026 +0400 Merge pull request #37682 from stankiewicz/cherrypick-kafka-eos Cherrypick kafka eos optimization .../beam/sdk/io/kafka/KafkaExactlyOnceSink.java | 28 +++++++++++++++++-- .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 32 ++++++++++++++++++++++ .../sdk/io/kafka/upgrade/KafkaIOTranslation.java | 7 +++++ .../io/kafka/upgrade/KafkaIOTranslationTest.java | 2 ++ 4 files changed, 66 insertions(+), 3 deletions(-)
