spring-cloud-alibaba DefaultMQPushConsumer set CONSUME_FROM_LAST_OFFSET does't work

6za6bjd0 于 3个月前发布在 Spring

关注(0)|答案(2)|浏览(84)

For a new consumer group, call

DefaultMQPushConsumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);

offsetStore.readOffset(mq, ReadOffsetType.READ_FROM_STORE) never return -1

so it still pulls all the msgs in the topic. If it is bug, i want to solve it.

spring-cloud-alibaba

来源：https://github.com/alibaba/spring-cloud-alibaba/issues/1181

2条答案

按热度按时间

Not supported, refer RocketMQConsumerProperties

赞(0）回复(0）举报 3个月前

refer #488

赞(0）回复(0）举报 3个月前

相关问题

热门标签

Java query python Node 开发语言 request Util 数据库 Table 后端算法 Logger Message Element Parser

最新问答

xxl-job 安全组扫描到执行器端口服务存在信息泄露漏洞
回答(1) 发布于 3个月前
xxl-job 不能和nacos兼容？
回答(3) 发布于 3个月前
xxl-job 任务执行完后无法结束，日志一直转圈
回答(3) 发布于 3个月前
xxl-job-admin页面上查看调度日志样式问题
回答(1) 发布于 3个月前
xxl-job 参数512字符限制能否去掉
回答(1) 发布于 3个月前