环境信息

canal version 1.1.3 mysql version 5.7.20

问题描述

Canal Server 对接 RocketMQ集群环境（2主2从集群，Broker a 和 Broker b），instance.properties配置信息如下

mq config

canal.mq.topic=example canal.mq.dynamicTopic=.\.. #canal.mq.partition=0

hash partition config

topic默认队列大小为4

canal.mq.partitionsNum=4

基于表名进行hash

canal.mq.partitionHash=.\..

解析的Binlog数据一直投递到Broker a, Broker b中无数据 (担心热点表数据过大，一直投递到同一个Broker对集群性能产生影响）

期待结果

期望： 根据表名Hash, 不同的表可以分散到不现的Broker, 数据在RocketMQ上均衡分布

现执行情况

实际：解析的Binlog数据一直投递到Broker a, Broker b中无数据

原提问者GitHub用户