You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ec...@apache.org on 2018/04/10 14:11:41 UTC
[beam] 01/01: Merge pull request #5019 from
aromanenko-dev/BEAM-2852-nexmark-kafka-source-sink
This is an automated email from the ASF dual-hosted git repository.
echauchot pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 506fb323dc465bcd48bff7f1ab82c9df308a243b
Merge: 717c059 6df0add
Author: Etienne Chauchot <ec...@apache.org>
AuthorDate: Tue Apr 10 16:11:33 2018 +0200
Merge pull request #5019 from aromanenko-dev/BEAM-2852-nexmark-kafka-source-sink
Merge pull request #5019: [BEAM-2852] Add support for Kafka as source/sink on Nexmark
sdks/java/nexmark/build.gradle | 2 +
sdks/java/nexmark/pom.xml | 31 +++++++-
.../apache/beam/sdk/nexmark/NexmarkLauncher.java | 92 ++++++++++++++++++++++
.../apache/beam/sdk/nexmark/NexmarkOptions.java | 20 +++++
.../org/apache/beam/sdk/nexmark/NexmarkUtils.java | 12 ++-
5 files changed, 153 insertions(+), 4 deletions(-)
--
To stop receiving notification emails like this one, please contact
echauchot@apache.org.