Replies: 1 comment
-
整个方案可行,有一些建议
|
Beta Was this translation helpful? Give feedback.
0 replies
# for free
to join this conversation on GitHub.
Already have an account?
# to comment
-
我对RocketMQ5的新特性分级存储很感兴趣。
我想实验一种场景:通过共享的分级存储,broker节点master0缩容下线后,新建立的节点master1完全接管master0已发送且未被消费的消息,继续被消费。
在实际过程中遇到一些问题:新建立的节点master1挂载了共享的分级存储,但无法消费到master0已发送未被消费的消息
我做了一些尝试:
1、原节点master0发送消息后下线,新节点master1使用master0的副本建立,brokerName这些配置一致。挂载共享的分级存储,但挂载的本地存储store不同。
2、在1的基础,手动复制本地store中tieredStoreMetadata.json到新节点master1,依然无法消费到共享分级存储中master0的消息。
3、在1的基础,手动复制本地store中tieredStoreMetadata.json、topic.json到新节点master1,可以消费到原节点master0中分级存储的消息了。
想请教:
1、这种利用共享的分级存储实现扩缩容,新节点接管缩容节点的场景,是否存在一些对缩容节点本地store数据的依赖?具体的操作步骤是怎样的?比如需要转移本地存储中tieredStoreMetadata.json、topic.json等到新节点本地存储,并挂载共享的分级存储才可以实现接管缩容节点的分级存储数据?
2、如果是brokerName等配置都不同的新节点master1,是否无法实现接管原节点master0读取分级存储数据?如果可以,要如何操作?
另外,我的RocketMQ版本是5.3,测试是K8S的环境下,测试是通过mqadmin工具的produce和consume收发消息。
Beta Was this translation helpful? Give feedback.
All reactions