二阶段，处理完本地事物中业务得到事物状态， 根据 offset 查找到 commitLog 中 的 prepared 消息，设置消息状态 commitType 或者 rollbackType ， 让后将信息添加到 commitLog 中， 其实二阶段生成了两条消息 事物消息发送 三：Broker prepared 状态的消息， 将 commit 或者 rollback 的消息对应的 prepared 消息删除 重建 StateTable, 将上面过滤出的 prepared 消息，添加到事物状态表文件中 这个事物状态表 transstable 的作用是定期（1 分钟）将状态为 prepared 事物回查 producer 端 redolog 这个队列其实标记消费到哪了， 当机或者添加，会导致分配到 mqSet 变 化， a) 将不在被本 consumer 消费的 messagequeue 的 ProcessQueue 删除， 其实是设 置 ProcessQueue 的 droped 属性为 true b) 将超过两份中没有拉取动作 ProcessQueue 删除 //TODO 为什么要删除掉，两分钟后来了消息怎么办? // 2) 添加新增队列，

Broker 启动流程中，会构建 TopicConfigManager 对象，其构造方法中 首先会判断是否开启了允许自动创建主题，如果启用了自动创建主题，则向 topicConfigT able 中添加默认主题的路由信息。 TopicConfigManager 构造方法： 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 21 > 1.2 生产环境中，autoCreateTopicEnable 从主从同步集群升级到 DLedger 集群，用户最关心的还是升级后的集群是否能够兼 容原先的数据，即原先存储在消息能否能被消息消费者消费端，甚至于能否查询到。 为了方便后续验证，首先我使用下述程序向 mq 集群中添加了一篇方便查询的消息 （设置消息的 key）。 public class Producer { public static void main(String[] args) throws MQClientException 温馨提示：示例中由于版本是一样，实际过程中，版本需要升级，故需先下载最新的版 本，然后将老集群中的 store 目录完整的拷贝到新集群的 store 目录。 Step2：依次在三台服务器的 broker.conf 配置文件中添加与 dledger 相关的配置 属性，修改后的 broker 配置属性如下： 192.168.0.220 broker 配置文件如下： brokerClusterName = DefaultCluster

Page 17 of 18 如何登录 Apache RocketMQ 的 Nameserver 和 Broker Node？ 1. 使用 ssh-add 命令添加 pem keypair 举例: ssh-add -k /Users/username/tmp/rocketmq.pem 2. 登录到 Bastion Host 举例：ssh -A ec

Page 20 of 21 如何登录 Apache RocketMQ 的 Nameserver 和 Broker Node？ 1. 使用 ssh-add 命令添加 pem keypair 举例: ssh-add -k /Users/username/tmp/rocketmq.pem 2. 登录到 Bastion Host 举例：ssh -A ec