This closes #1048
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0e6b3794 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0e6b3794 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0e6b3794 Branch: refs/heads/master Commit: 0e6b3794c069bf30f7402492a3f61958873142cd Parents: 420a718 e0c704f Author: Dan Halperin <[email protected]> Authored: Wed Feb 1 14:29:44 2017 -0800 Committer: Dan Halperin <[email protected]> Committed: Wed Feb 1 14:29:44 2017 -0800 ---------------------------------------------------------------------- .../streaming/KafkaStreamingTest.java | 4 +- .../ResumeFromCheckpointStreamingTest.java | 2 +- sdks/java/io/kafka/pom.xml | 6 + .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 619 ++++++++----------- .../apache/beam/sdk/io/kafka/KafkaIOTest.java | 17 +- 5 files changed, 287 insertions(+), 361 deletions(-) ----------------------------------------------------------------------
