Repository: incubator-beam Updated Branches: refs/heads/master c94822637 -> e3d170c13
Closes #904 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e3d170c1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e3d170c1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e3d170c1 Branch: refs/heads/master Commit: e3d170c1330f895522af36fc2cdb4622d5b4884e Parents: c948226 56c7002 Author: Dan Halperin <[email protected]> Authored: Mon Aug 29 21:21:46 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Mon Aug 29 21:21:46 2016 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 25 ++++++++++---------- 1 file changed, 12 insertions(+), 13 deletions(-) ----------------------------------------------------------------------
