You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "Jingsong Lee (JIRA)" <ji...@apache.org> on 2017/05/10 11:45:04 UTC
[jira] [Created] (BEAM-2248) KafkaIO support to use start read time
to set start offset
Jingsong Lee created BEAM-2248:
----------------------------------
Summary: 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)