This closes #3044: [BEAM-2248] KafkaIO support to use start read time to set start offset
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/94d677dc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/94d677dc Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/94d677dc Branch: refs/heads/master Commit: 94d677dc97330b424ce960310f23e7992f67bfd6 Parents: 49067b1 d29e353 Author: Eugene Kirpichov <kirpic...@google.com> Authored: Tue May 30 14:58:28 2017 -0700 Committer: Eugene Kirpichov <kirpic...@google.com> Committed: Tue May 30 14:58:28 2017 -0700 ---------------------------------------------------------------------- sdks/java/io/kafka/pom.xml | 2 +- .../apache/beam/sdk/io/kafka/ConsumerSpEL.java | 56 +++++++++ .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 44 ++++++- .../apache/beam/sdk/io/kafka/KafkaIOTest.java | 122 ++++++++++++++++--- 4 files changed, 205 insertions(+), 19 deletions(-) ----------------------------------------------------------------------
