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)
