From 0197482618bae84bb60c9f7302ed57fca8872951 Mon Sep 17 00:00:00 2001 From: agapple Date: Tue, 11 Dec 2018 20:17:08 +0800 Subject: [PATCH] fixed partitionHash format --- deployer/src/main/resources/example/instance.properties | 2 +- .../java/com/alibaba/otter/canal/common/MQMessageUtils.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/deployer/src/main/resources/example/instance.properties b/deployer/src/main/resources/example/instance.properties index 2a1d8aac..4e09a08d 100644 --- a/deployer/src/main/resources/example/instance.properties +++ b/deployer/src/main/resources/example/instance.properties @@ -48,5 +48,5 @@ canal.mq.topic=example canal.mq.partition=0 # hash partition config #canal.mq.partitionsNum=3 -#canal.mq.partitionHash=test.table#id^name,.*\\..* +#canal.mq.partitionHash=test.table:id^name,.*\\..* ################################################# 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 c99df2f4..e6080eba 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 @@ -36,10 +36,10 @@ public class MQMessageUtils { List datas = Lists.newArrayList(); String[] pkHashConfigArray = StringUtils.split(pkHashConfigs, ","); - // schema.table#id^name + // schema.table:id^name for (String pkHashConfig : pkHashConfigArray) { PartitionData data = new PartitionData(); - int i = pkHashConfig.lastIndexOf("#"); + int i = pkHashConfig.lastIndexOf(":"); if (i > 0) { data.pkNames = Lists.newArrayList(StringUtils.split(pkHashConfig.substring(i + 1), '^'));