From 2a38bca34ba322b547155b7fd14a3f60f88b1bf7 Mon Sep 17 00:00:00 2001 From: mcy Date: Fri, 9 Nov 2018 16:52:34 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E6=95=B4=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- deployer/src/main/resources/example/instance.properties | 2 +- .../main/java/com/alibaba/otter/canal/common/MQProperties.java | 3 --- 2 files changed, 1 insertion(+), 4 deletions(-) diff --git a/deployer/src/main/resources/example/instance.properties b/deployer/src/main/resources/example/instance.properties index c2e42618..55566641 100644 --- a/deployer/src/main/resources/example/instance.properties +++ b/deployer/src/main/resources/example/instance.properties @@ -45,7 +45,7 @@ canal.instance.filter.black.regex= # mq config canal.mq.topic=example -# 但分区指定分区0 +# 多分区指定分区0 canal.mq.partition=0 # 多分区指定分区数量 #canal.mq.partitionsNum=3 diff --git a/server/src/main/java/com/alibaba/otter/canal/common/MQProperties.java b/server/src/main/java/com/alibaba/otter/canal/common/MQProperties.java index c61710e1..29375e2f 100644 --- a/server/src/main/java/com/alibaba/otter/canal/common/MQProperties.java +++ b/server/src/main/java/com/alibaba/otter/canal/common/MQProperties.java @@ -21,9 +21,6 @@ public class MQProperties { private Long canalGetTimeout = 100L; private boolean flatMessage = true; - // private List canalDestinations = new - // ArrayList(); - public static class CanalDestination { private String canalDestination;