名称，消息发送 topic 名称，使用的队列 数量为 DefaultMQProducer#defaultTopicQueueNums，即默认为 4。 Step4：Broker 端收到消息后的处理流程 服务端收到消息发送的处理器为：SendMessageProcessor，在处理消息发送时， 会调用 super.msgCheck 方法： AbstractSendMessageProcessor#msgCheck 端不存在该主题的路由配置(路由信息),此时如果 Broker 中存在默认主题的路由配 置信息，则根据消息发送请求中的队列数量，在 Broker 创建新 Topic 的路由信息。这样 Broker 服务端就会存在主题的路由信息。 在 Broker 端的 topic 配置管理器中存在的路由信息，一会向 Nameserver 发送心跳 包，汇报到 Nameserver，另一方面会有一个定时任务，定时存储在 Topic 的路由信息，如果存在，说明启用了 autoCreateTopi cEnable，则在 TopicConfigManager 中创建新 Topic 的路由信息，此时存在与 Broker 服务端的内存中，然后本次消息发送结束。此时，在 NameServer 中还不存在新创建的 Topic 的路由信息。 这里有三个关键点： 1. 启用 autoCreateTopicEnable 创建主题时，在

............................................................ 52 二：NettyRemotingServer Remoting 服务端实现 .............................................................. 53 三：NettyRemotingClient ....... 候（因为broker master 和slave都构建了HAClient） 会主动连接 master 获取 SocketChannel Master 监听 Slave 请求的端口，默认为服务端口+1 接收 slave 上传的 offset long 类型 int pos = this.byteBufferRead.position() - (this.byteBufferRead.position() 二：NettyRemotingServer Remoting 服务端实现 broker 启动初始化 NettyRemotingServer ， 向 netty 注册 handler NettyEncoder 协议编码器，将 RemotingCommand

可观测性能力云原生化，OpenTelemetry 标准化 • Kubernetes 一键式部署扩容交付 W r i t e h e r e S o m e t h i n g Ab o u t 全新 POP 消费模型 服务端负载均衡  消除 Consumer 与 Queue 的 Binding 关 系，一个 Queue 可以由多个消费者消费  无 rebalance ，降低消费延迟概率  集群中某些消费端假死不影响整体消费进度

FALSE 如果发送消息返回 sendResult，但是 sendStatus!=SEND_OK，是否重试发送 maxMessageSize 131072 客户端限制的消息大小，超过报错，同时 服务端也会限制 transactionCheckListener 事务消息回查监听器，如果发送事务消息， 必须设置 checkThreadPoolMinSize 1 Broker 回查