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

代码整理

Browse Source
This commit is contained in:
mcy
2018-11-09 16:52:34 +08:00
parent c5bd42bbf1
commit 2a38bca34b
2 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -45,7 +45,7 @@ canal.instance.filter.black.regex=
# mq config # mq config
canal.mq.topic=example canal.mq.topic=example
# 但分区指定分区0 # 多分区指定分区0
canal.mq.partition=0 canal.mq.partition=0
# 多分区指定分区数量 # 多分区指定分区数量
#canal.mq.partitionsNum=3 #canal.mq.partitionsNum=3

3
server/src/main/java/com/alibaba/otter/canal/common/MQProperties.java
View File

@@ -21,9 +21,6 @@ public class MQProperties {
private Long canalGetTimeout = 100L; private Long canalGetTimeout = 100L;
private boolean flatMessage = true; private boolean flatMessage = true;
// private List<CanalDestination> canalDestinations = new
// ArrayList<CanalDestination>();
public static class CanalDestination { public static class CanalDestination {
private String canalDestination; private String canalDestination;