Merge pull request #1641 from wangsaner/master

修改canal.mq.partitionHash散列规则,使其支持同库下的不同表hash至相同分区
This commit is contained in:
agapple
2019-03-28 16:58:31 +08:00
committed by GitHub

View File

@@ -230,6 +230,7 @@ public class MQMessageUtils {
}
}
} else {
hashCode = database.hashCode();
for (CanalEntry.Column column : rowData.getAfterColumnsList()) {
if (checkPkNamesHasContain(hashMode.pkNames, column.getName())) {
hashCode = hashCode ^ column.getValue().hashCode();