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

Posted to commits@beam.apache.org by ke...@apache.org on 2025/03/18 17:19:50 UTC

(beam) branch master updated (df5dd4e0b87 -> e71fdce4d69)

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

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


    from df5dd4e0b87 Update roadmap page 28342 (#34330)
     add e71fdce4d69 [KafkaIO] Fix average record size data race and backlog estimation (#34165)

No new revisions were added by this update.

Summary of changes:
 build.gradle.kts                                   |   1 +
 .../build.gradle => io/kafka/jmh/build.gradle.kts} |  19 +-
 .../sdk/io/kafka/jmh/KafkaIOUtilsBenchmark.java    | 235 +++++++++++++++++++++
 .../beam/sdk/io/kafka/jmh}/package-info.java       |   4 +-
 .../org/apache/beam/sdk/io/kafka/KafkaIOUtils.java |  43 +++-
 .../beam/sdk/io/kafka/KafkaUnboundedReader.java    |  20 +-
 .../beam/sdk/io/kafka/ReadFromKafkaDoFn.java       |  94 +++------
 settings.gradle.kts                                |   1 +
 8 files changed, 315 insertions(+), 102 deletions(-)
 copy sdks/java/{container/java17/build.gradle => io/kafka/jmh/build.gradle.kts} (64%)
 create mode 100644 sdks/java/io/kafka/jmh/src/main/java/org/apache/beam/sdk/io/kafka/jmh/KafkaIOUtilsBenchmark.java
 copy sdks/java/{core/jmh/src/main/java/org/apache/beam/sdk/jmh/io => io/kafka/jmh/src/main/java/org/apache/beam/sdk/io/kafka/jmh}/package-info.java (91%)