This closes #3985
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aa26f4bf Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/aa26f4bf Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/aa26f4bf Branch: refs/heads/master Commit: aa26f4bf71d72989da82927bd1565e5722a1f8d8 Parents: 16b9d58 56b512f Author: chamik...@google.com <chamik...@google.com> Authored: Mon Oct 30 16:40:54 2017 -0700 Committer: chamik...@google.com <chamik...@google.com> Committed: Mon Oct 30 16:40:54 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) ----------------------------------------------------------------------
