根据您的评论,您有两个 RocketMQ 集群,一条消息应该复制到另一个 RocketMQ 集群。
所以这是一个消息复制。
你有两个选择:
实现发送消息挂钩
AbstractPluginMessageStore
使用扩展并使用代理配置加载它的 messageStore 插件
两者都需要自己实现复制。
但是,如果你让他们成为同一个经纪人组,那就很容易了。
只需将rocketmq-b作为rocketmq-a的slave,部署在不同的机房即可。
那么rocketmq-b将只提供读操作,并且总是从master复制数据