LetLetMe commented on code in PR #8600:
URL: https://github.com/apache/rocketmq/pull/8600#discussion_r1759649104
##########
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java:
##########
@@ -381,6 +378,14 @@ public boolean load() {
return result;
}
+ public void loadCheckPoint() throws IOException {
Review Comment:
是这样的，需要按照issuse里边的配置来进行原地升级，如果直接改storeType，旧的消息将消费不到了，cq升级有俩种方案，一种是broker启动的时候做转换，一种是双写一段时间然后切流，我们选择了后者，这里的原因在issue里边有写，为了稳定性和不阻塞broker启动考虑的
Yes, it is necessary to perform an in-place upgrade according to the
configuration in the issue. If you directly change the storeType, old messages
will not be consumable. There are two solutions for upgrading the consume queue
(CQ): one is to perform the conversion when the broker starts, and the other is
to double-write for a period of time and then switch the flow. We chose the
latter, as explained in the issue, for reasons of stability and to avoid
blocking the broker startup.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
