Преглед на файлове

去掉kafka canalBatchSize使用默认50

mcy преди 7 години
родител
ревизия
bcf30a9a05
променени са 2 файла, в които са добавени 1 реда и са изтрити 3 реда
  1. 0 2
      deployer/src/main/resources/kafka.yml
  2. 1 1
      server/src/main/java/com/alibaba/otter/canal/kafka/KafkaProperties.java

+ 0 - 2
deployer/src/main/resources/kafka.yml

@@ -3,8 +3,6 @@ retries: 0
 batchSize: 16384
 lingerMs: 1
 bufferMemory: 33554432
-# canal的批次大小,单位 k,量大建议改为1M
-canalBatchSize: 50
 filterTransactionEntry: true
 
 canalDestinations:

+ 1 - 1
server/src/main/java/com/alibaba/otter/canal/kafka/KafkaProperties.java

@@ -19,7 +19,7 @@ public class KafkaProperties {
     private int                    lingerMs               = 1;
     private long                   bufferMemory           = 33554432L;
     private boolean                filterTransactionEntry = true;
-    private int                    canalBatchSize         = 5;
+    private int                    canalBatchSize         = 50;
 
     private List<CanalDestination> canalDestinations      = new ArrayList<CanalDestination>();