From 9826948ebb885dedebd6bd52fae5363e94286040 Mon Sep 17 00:00:00 2001 From: wangsaner Date: Thu, 28 Mar 2019 16:01:02 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9canal.mq.partitionHash?= =?UTF-8?q?=E6=95=A3=E5=88=97=E8=A7=84=E5=88=99=EF=BC=8C=20=E5=BD=93?= =?UTF-8?q?=E6=8C=87=E6=98=8Epk=E7=BA=A7=E5=81=9A=E5=88=86=E5=8C=BA?= =?UTF-8?q?=EF=BC=88schema.table:pk1^pk2=EF=BC=89=E6=97=B6=EF=BC=8C?= =?UTF-8?q?=E7=94=B1table.hashCode()^column.getValue().hashCode()=E6=94=B9?= =?UTF-8?q?=E4=B8=BAdatabase.hashCode()^column.getValue().hashCode()?= =?UTF-8?q?=EF=BC=8C=E4=BB=8E=E8=80=8C=E6=94=AF=E6=8C=81=E5=90=8C=E5=BA=93?= =?UTF-8?q?=E4=B8=8B=E4=B8=8D=E5=90=8C=E8=A1=A8hash=E8=87=B3=E7=9B=B8?= =?UTF-8?q?=E5=90=8C=E5=88=86=E5=8C=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/alibaba/otter/canal/common/MQMessageUtils.java | 1 + 1 file changed, 1 insertion(+) diff --git a/server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java b/server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java index acff1751..f1ed1c86 100644 --- a/server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java +++ b/server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java @@ -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();