mq

./mqadmin resetOffsetByTime -g 消费组名 -n namesrv地址 -s now -t topic名字

./mqadmin consumerProgress -g 消费组名 -l topic名字 -n namesrv地址

properties.put(“ConsumeFromWhere”, “ConsumeFromLast”);

properties.put(PropertyKey.ConsumeFrom_Where, PropertyKey.ConsumeFrom_Last_Value);