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%)
