From bcf30a9a05934e30220b9f8e6aec41f2d0246b6f Mon Sep 17 00:00:00 2001
From: mcy <rewerma@163.com>
Date: Tue, 28 Aug 2018 15:52:36 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E6=8E=89kafka=20canalBatchSize?=
 =?UTF-8?q?=E4=BD=BF=E7=94=A8=E9=BB=98=E8=AE=A450?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 deployer/src/main/resources/kafka.yml                           | 2 --
 .../java/com/alibaba/otter/canal/kafka/KafkaProperties.java     | 2 +-
 2 files changed, 1 insertion(+), 3 deletions(-)

diff --git a/deployer/src/main/resources/kafka.yml b/deployer/src/main/resources/kafka.yml
index 93d4d557..8abf4934 100644
--- a/deployer/src/main/resources/kafka.yml
+++ b/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:
diff --git a/server/src/main/java/com/alibaba/otter/canal/kafka/KafkaProperties.java b/server/src/main/java/com/alibaba/otter/canal/kafka/KafkaProperties.java
index 140ce965..9194c0ab 100644
--- a/server/src/main/java/com/alibaba/otter/canal/kafka/KafkaProperties.java
+++ b/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>();