This closes #2344
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/47821ad6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/47821ad6 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/47821ad6 Branch: refs/heads/master Commit: 47821ad695f67977c775f62b6f8791ca109a7d0b Parents: 81474ae 930c27f Author: Aviem Zur <aviem...@gmail.com> Authored: Sat Apr 29 18:16:17 2017 +0300 Committer: Aviem Zur <aviem...@gmail.com> Committed: Sat Apr 29 18:16:17 2017 +0300 ---------------------------------------------------------------------- .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 65 +++++++++- .../apache/beam/sdk/io/kafka/KafkaIOTest.java | 130 +++++++++++++++++++ 2 files changed, 194 insertions(+), 1 deletion(-) ----------------------------------------------------------------------
