This closes #2797
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b414f8de Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b414f8de Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b414f8de Branch: refs/heads/master Commit: b414f8de90cd89ac76cd9cbe43b2d2d0049faa71 Parents: 1197bef 5dac56f Author: Aviem Zur <aviem...@gmail.com> Authored: Mon May 1 11:25:25 2017 +0300 Committer: Aviem Zur <aviem...@gmail.com> Committed: Mon May 1 11:25:25 2017 +0300 ---------------------------------------------------------------------- .../apache/beam/sdk/io/kafka/KafkaIOTest.java | 41 +++++++++++++------- 1 file changed, 26 insertions(+), 15 deletions(-) ----------------------------------------------------------------------
