This closes #2364
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5f72b83c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5f72b83c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5f72b83c Branch: refs/heads/master Commit: 5f72b83c054845ecfc0be03e27acfc24a676a936 Parents: 0b8932f 37b0d45 Author: Eugene Kirpichov <[email protected]> Authored: Fri Mar 31 16:51:38 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Fri Mar 31 16:51:38 2017 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 11 ++++++++- .../apache/beam/sdk/io/kafka/KafkaIOTest.java | 24 ++++++++++++++++++++ 2 files changed, 34 insertions(+), 1 deletion(-) ----------------------------------------------------------------------
