chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixed partitionHash format

Browse Source
This commit is contained in:
agapple
2018-12-11 20:17:08 +08:00
parent 72bad4d54c
commit 0197482618
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
deployer/src/main/resources/example/instance.properties
View File

@@ -48,5 +48,5 @@ canal.mq.topic=example
canal.mq.partition=0 canal.mq.partition=0
# hash partition config # hash partition config
#canal.mq.partitionsNum=3 #canal.mq.partitionsNum=3
#canal.mq.partitionHash=test.table#id^name,.*\\..* #canal.mq.partitionHash=test.table:id^name,.*\\..*
################################################# #################################################

4
server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java
View File

@@ -36,10 +36,10 @@ public class MQMessageUtils {
List<PartitionData> datas = Lists.newArrayList(); List<PartitionData> datas = Lists.newArrayList();
String[] pkHashConfigArray = StringUtils.split(pkHashConfigs, String[] pkHashConfigArray = StringUtils.split(pkHashConfigs,
","); ",");
// schema.table#id^name // schema.table:id^name
for (String pkHashConfig : pkHashConfigArray) { for (String pkHashConfig : pkHashConfigArray) {
PartitionData data = new PartitionData(); PartitionData data = new PartitionData();
int i = pkHashConfig.lastIndexOf("#"); int i = pkHashConfig.lastIndexOf(":");
if (i > 0) { if (i > 0) {
data.pkNames = Lists.newArrayList(StringUtils.split(pkHashConfig.substring(i + 1), data.pkNames = Lists.newArrayList(StringUtils.split(pkHashConfig.substring(i + 1),
'^')); '^'));