Closes #271
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c2146b9f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c2146b9f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c2146b9f Branch: refs/heads/master Commit: c2146b9f9d6a1f39a5699725ccb51829d751b88a Parents: 0e62c29 5b6ebd1 Author: Dan Halperin <[email protected]> Authored: Sun Jun 5 18:21:45 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Sun Jun 5 18:21:45 2016 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 441 ++++++++++++++++++- .../apache/beam/sdk/io/kafka/KafkaIOTest.java | 300 ++++++++++++- 2 files changed, 705 insertions(+), 36 deletions(-) ----------------------------------------------------------------------
