This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 69ab938 Merge pull request #10751: Embed audio podcasts players to
webpage instead of links that play the podcasts
add 5a51cb5 [BEAM-7310] Add support of Confluent Schema Registry for
KafkaIO
add 39c4a9f Merge pull request #10563: [BEAM-7310] Add support of
Confluent Schema Registry for KafkaIO
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/Repositories.groovy | 6 +
sdks/java/io/kafka/build.gradle | 7 +
.../beam/sdk/io/kafka/BasicCSRClientProvider.java | 61 +++++
.../beam/sdk/io/kafka/CSRClientProvider.java} | 20 +-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 150 ++++++++++--
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 23 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 261 ++++++++++++++++++++-
.../beam/sdk/io/kafka/TestCSRClientProvider.java | 64 +++++
8 files changed, 565 insertions(+), 27 deletions(-)
create mode 100644
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/BasicCSRClientProvider.java
copy
sdks/java/io/{amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/SnsClientProvider.java
=> kafka/src/main/java/org/apache/beam/sdk/io/kafka/CSRClientProvider.java}
(65%)
create mode 100644
sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/TestCSRClientProvider.java
