This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 0715b66 [BEAM-12548] Add examples of Equals and EqualsList to
equals_test.go (#15112)
add d6088d3 [BEAM-12076] Adds a Kafka external read transform for reading
with metadata (#15028)
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/io/xlang/kafkaio/kafka.go | 2 +-
.../sdk/expansion/ExternalTransformRegistrar.java | 2 +-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 227 ++++++++++++++++++---
.../beam/sdk/io/kafka/KafkaIOExternalTest.java | 149 ++++++++++++--
.../apache_beam/examples/kafkataxi/kafka_taxi.py | 36 +++-
sdks/python/apache_beam/io/kafka.py | 12 +-
6 files changed, 377 insertions(+), 51 deletions(-)
