This is an automated email from the ASF dual-hosted git repository.
bhulette pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 4861df4 Allow extension of SdkContainerImageBuilder (#13756)
add 62c304d [BEAM-11411] [BEAM-11410] Kafka to pub sub E2E test (#13636)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 1 +
examples/java/build.gradle | 4 +-
.../complete/kafkatopubsub/KafkaToPubsub.java | 10 +-
.../kafkatopubsub/kafka/consumer/Utils.java | 8 ++
.../options/KafkaToPubsubOptions.java | 6 +
.../kafkatopubsub/KafkaToPubsubE2ETest.java | 129 +++++++++++++++++++++
.../apache/beam/sdk/io/gcp/pubsub/TestPubsub.java | 42 ++++++-
7 files changed, 190 insertions(+), 10 deletions(-)
create mode 100644 examples/java/src/test/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaToPubsubE2ETest.java
|