sun
sun
### RocketMQ同机房就近生产和消费机制。 RocketMQ注册、发现机制 - Broker - 间隔30秒发送broker上的Topic全量信息到所有Nameserv。broker启动的时候也是延迟注册到Namesrv上的。当有topic发生变更时TopicConfigManager.dataVersion发生变更。 - 当有topic创建和更新时，broker立刻发送Topic增量信息到所有Namesrv。同时触发Namesrv的BrokerLiveInfo.dataVersion发生变更。 - Namesrv - 保存集群和broker关系、broker信息（brokerName和地址）、broker真实连接和topic版本号，topic信息。 - 调度线程每10秒钟检查一次，如果发现一个broker 120秒都没有更新注册信息，则删除和这个broker相关的所有信息。 - Producer&Consumer - Producer第一次发送Message时，会同步向namesrv请求topic路由信息 - Consumer启动过程中会向namesrv请求topic路由信息 - 每隔30秒向namesrv拉取一次topic路由信息，根据路由信息内容（不是版本号）判断是否变化，发生变化更新 - 总结： Producer第一次发送消息时会同步向namesrv请求topic路由信息，然后默认轮询往每个Queue发送消息。 Consumer启动时获取topic路由信息，然后请求broker获取consumer实例列表，最后根据consumer的数量和负载均衡算法给consumer分配queue。 ### 实现rocketmq同机房就近生产和消费：...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version linux cenos pulsar version 2.10.1 ### Minimal reproduce step Configure topic level Geo...