[
https://issues.apache.org/jira/browse/STORM-563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14219012#comment-14219012
]
ASF GitHub Bot commented on STORM-563:
--------------------------------------
Github user harshach commented on the pull request:
https://github.com/apache/storm/pull/321#issuecomment-63761302
@nathanmarz rethinking a bit on this patch. Having both startOffsetTime
and forceFromStart is confusing a bit from user point of view. If user deploys
a topology and doesn't set forceFromStart and by default startOffsetTime is
EarliestTime. It doesn't read from the beginning of the queue.
If the user sets forceFromStart to true and later kills the topology and
redeploys it they must remember to turn off the forceFromStart to start from
where they left off. I'll send a updated patch.
> Kafka Spout doesn't pick up from the beginning of the queue unless
> forceFromStart specified
> -------------------------------------------------------------------------------------------
>
> Key: STORM-563
> URL: https://issues.apache.org/jira/browse/STORM-563
> Project: Apache Storm
> Issue Type: Bug
> Reporter: Sriharsha Chintalapani
> Assignee: Sriharsha Chintalapani
>
> KafkaUtil.getOffset starts from LatestTime unless forceFromStart specified.
> It should pick this from KafkaConfig.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
