[
https://issues.apache.org/jira/browse/STORM-2992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550547#comment-16550547
]
Jing Chen commented on STORM-2992:
----------------------------------
[~Srdo] I finished code changes for storm side, however, I noticed that
MockConsumer we are using for Kafka in unit tests missed implementation for
offsetsForTimes, it simply throws UnsupportedOperationException. Do you have
any idea how we can proceed on unit tests on this scenario? Thanks :)
> Add support for starting storm-kafka-client spout consumer at a specific
> timestamp
> -----------------------------------------------------------------------------------
>
> Key: STORM-2992
> URL: https://issues.apache.org/jira/browse/STORM-2992
> Project: Apache Storm
> Issue Type: Improvement
> Affects Versions: 2.0.0
> Reporter: Stig Rohde Døssing
> Assignee: Jing Chen
> Priority: Minor
>
> The 0.10.1.0 KafkaConsumer has support for getting the offset corresponding
> to a given timestamp (the offsetsForTimes method). We could provide a new
> FirstPollOffsetStrategy to allow topologies to start consumption at a
> specific timestamp, instead of earliest or latest offset.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
