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

Posted to commits@beam.apache.org by yh...@apache.org on 2025/04/16 18:16:21 UTC

(beam) branch master updated (9331662c934 -> 8de3d3d74f2)

This is an automated email from the ASF dual-hosted git repository.

yhu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from 9331662c934 consume flow control settings updates from job settings (#34539)
     add 8de3d3d74f2 [KafkaIO] BUG FIX : fix-ReadFromKafkaViaSDF-bug-shall-set-coder (#34505)

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                         |   1 +
 .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java |  66 +++++----
 .../org/apache/beam/sdk/io/kafka/KafkaIOIT.java    | 157 +++++++++++++++++++++
 3 files changed, 200 insertions(+), 24 deletions(-)