[ 
https://issues.apache.org/jira/browse/ROCKETMQ-248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16101439#comment-16101439
 ] 

Yu Kaiyuan commented on ROCKETMQ-248:
-------------------------------------

[~Jaskey]
I think the usage of `consumeFromWhere ` is to let the consumers determine 
where they wants to start consuming from.
And the behavior of the option should match the expectation.

In the very situation of a new scaled queue of an *existing topic & existing 
subscription*,
consumer should apparently consume from the beginning of the new scaled queue 
to avoid message loss.

And the patch already takes it into consideration. 



> ConsumeFromWhere does not always work as expected
> -------------------------------------------------
>
>                 Key: ROCKETMQ-248
>                 URL: https://issues.apache.org/jira/browse/ROCKETMQ-248
>             Project: Apache RocketMQ
>          Issue Type: Improvement
>          Components: rocketmq-broker, rocketmq-client
>    Affects Versions: 4.0.0-incubating, 4.1.0-incubating
>            Reporter: Yu Kaiyuan
>            Assignee: yukon
>
> As a *brand new subscription*, consumer will be allowed to decide where to 
> start the consumption. And the options includes:
> * CONSUME_FROM_LAST_OFFSET
> * CONSUME_FROM_FIRST_OFFSET
> * CONSUME_FROM_TIMESTAMP
> But the fact is the option: `CONSUME_FROM_LAST_OFFSET` does not always work 
> as expected. Even if the subscription is new, the consumer still might 
> consume from the first message.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to