lizhiboo

@francisoliverlee following test would not throw exception ```java AbstractMessingActivityTest.testValidateTopic() assertThrows(GrpcProxyException.class, () -> messingActivity.validateTopic(Resource.newBuilder().setName(createString(128)).build())); ```

IMO, we can refer to affinity/anti-affinity in k8s. each broker can be labeled some tag, such as idc, rack and so on. namesrv hold broker's tag info through heartbeat. And...

> @lizhiboo Hello, do you think the above implementation is not in line with the original intention of the community design? Can I have a brief conversation with you? My...

> In the current design, different workerTasks handle different topics. One workerTask corresponds to one pullConsumer, which improves concurrency to a certain extent, so there is no problem using different...

> 是否有 rocketmq-replicator更详细的部署文档,根据官方文档部署不生效. > > 1. 创建俩套rocketmq 版本V4.5.1 > 2. 源mq 创建topic如下 > connector-cluster-topic > connector-config-topic > connector-offset-topic > connector-position-topic > replicatorTopic > 3. 配置文件 > > ``` > #current...

@15712852007 Travis CI failed, pls check it.