[ https://issues.apache.org/jira/browse/BEAM-2248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16030232#comment-16030232 ]
ASF GitHub Bot commented on BEAM-2248: -------------------------------------- Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/3044 > KafkaIO support to use start read time to set start offset > ---------------------------------------------------------- > > Key: BEAM-2248 > URL: https://issues.apache.org/jira/browse/BEAM-2248 > Project: Beam > Issue Type: New Feature > Components: sdk-java-extensions > Reporter: Jingsong Lee > Assignee: Jingsong Lee > > This Kafka 0.10.x adds support for a searchable index for each topic based > off of message timestamps. It enables consumer support for offset lookup by > timestamp. > So we can add a start read time to set start offset. -- This message was sent by Atlassian JIRA (v6.3.15#6346)