Closes #1071
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/93d2e374 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/93d2e374 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/93d2e374 Branch: refs/heads/master Commit: 93d2e374c31162bb28c474c3d454e6671b02a159 Parents: 3c73170 08c2f1c Author: Dan Halperin <dhalp...@google.com> Authored: Thu Oct 13 17:22:29 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Thu Oct 13 17:22:29 2016 -0700 ---------------------------------------------------------------------- .../beam/sdk/io/kafka/KafkaCheckpointMark.java | 8 +- .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 60 +++---- .../apache/beam/sdk/io/kafka/KafkaIOTest.java | 162 +++++++++++++++---- 3 files changed, 165 insertions(+), 65 deletions(-) ----------------------------------------------------------------------
