sdmq edited a comment on issue #217:
URL: https://github.com/apache/rocketmq-spring/issues/217#issuecomment-785536648
分析原因:
package org.apache.rocketmq.client.consumer.store;
public class LocalFileOffsetStore implements OffsetStore {
..................
public LocalFileOffsetStore(MQClientInstance mQClientFactory, String
groupName) {
this.mQClientFactory = mQClientFactory;
this.groupName = groupName;
this.storePath = LOCAL_OFFSET_STORE_DIR + File.separator +
this.mQClientFactory.getClientId() + File.separator + this.groupName +
File.separator + "offsets.json";
}
加载本地json 时出错,
解决办法:
根据LOCAL_OFFSET_STORE_DIR 这个目录 找到目录 一块删除了就可以
以windows为例:
C:\Users\{loginuser}.rocketmq_offsets
删除这个目录下所有文件即可
----------------------------------------------------------------
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]
