baomingyu opened a new issue #1135: The problem of new consumer with 'CONSUME_FROM_LAST_OFFSET' model URL: https://github.com/apache/rocketmq/issues/1135 when i create consumer using a new consumer group with 'CONSUME_FROM_LAST_OFFSET' model and subscribe a topic that has been created and has contained messages , it will consumer all exit messages rather than begin from last offset. I have found this problem is here .RebalancePushImpl.java -- > computePullFromWhere "case CONSUME_FROM_LAST_OFFSET" , when user new consumer group the result will be 0 rather than last offset or max offset ,because broker will not do return -1 . so it will be modified with such way 
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
