This closes #2111
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3b3d6b81 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3b3d6b81 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3b3d6b81 Branch: refs/heads/master Commit: 3b3d6b81a5fe0f09aaa52340fdc9e671b46e4d57 Parents: d84b067 52e2d3a Author: Sela <ans...@paypal.com> Authored: Wed Mar 1 19:29:05 2017 +0200 Committer: Sela <ans...@paypal.com> Committed: Wed Mar 1 19:29:05 2017 +0200 ---------------------------------------------------------------------- sdks/java/io/kafka/pom.xml | 7 +++ .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 49 ++++++++++++++++++ .../apache/beam/sdk/io/kafka/KafkaIOTest.java | 53 +++++++++++++++++++- 3 files changed, 108 insertions(+), 1 deletion(-) ----------------------------------------------------------------------
