Consumer

whatsmars-mq/whatsmars-mq-rocketmq-spring/src/main/java/org/hongxi/whatsmars/rocketmq/config/spring/Consumer.java

@@ -112,7 +112,6 @@ public class Consumer extends ClientConfig implements FactoryBean<DefaultMQPushC
         consumer = new DefaultMQPushConsumer(consumerGroup);
         consumer.setInstanceName(instanceName);
         consumer.setNamesrvAddr(namesrvAddr);
-        consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
         consumer.setMessageModel(messageModel);
         consumer.setConsumeThreadMin(consumeThreadMin);
         consumer.setConsumeThreadMax(consumeThreadMax);

whatsmars-mq/whatsmars-mq-sdk/src/main/java/org/hongxi/whatsmars/common/rocketmq/BaseConsumer.java

@@ -26,7 +26,6 @@ public abstract class BaseConsumer {
 
     protected void startConsume(String consumerGroup, String topic, String tags) throws MQClientException {
         consumer = new DefaultMQPushConsumer(consumerGroup);
-        consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
         consumer.subscribe(topic, tags);
         consumer.registerMessageListener(new MessageListenerConcurrently() {
             @Override
@@ -46,7 +45,6 @@ public abstract class BaseConsumer {
 
     protected void startConsumeOrderly(String consumerGroup, String topic, String tags) throws MQClientException {
         consumer = new DefaultMQPushConsumer(consumerGroup);
-        consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
         consumer.subscribe(topic, tags);
         consumer.registerMessageListener(new MessageListenerOrderly() {
             @Override