canal对接RocketMQ集群模式，使用partitionHash, binlog数据一直投递到

环境信息

canal version 1.1.4 mysql version 5.6.7

问题描述

Canal 对接 RocketMQ集群环境（2主2从集群，Broker a 和 Broker b），instance.properties配置信息如下 canal.mq.topic=migrate-my-test

主题路由

#canal.mq.dynamicTopic=mytest1.user,mytest2..,...* canal.mq.partition=0

分区配置

#topic默认队列8 canal.mq.partitionsNum=8 canal.mq.partitionHash=cp_test.my_test:id^name,cp_test.my_test_2:id,cp_test.my_test_3:id,cp_test.my_test_4:id,cp_test.my_test_5:id,cp_test.my_test_6:id 解析的Binlog数据一直投递到Broker a, Broker b中无数据

期待结果

根据表名partitionHash, 不同的表可以分散到不现的Broker, 数据在RocketMQ上分布均匀

实际执行情况

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

原提问者GitHub用户authorXiao