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;