From 62f975deeb421017b985ba912459421cef02b39b Mon Sep 17 00:00:00 2001
From: mcy <rewerma@163.com>
Date: Wed, 15 Aug 2018 14:26:55 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E4=B8=8A=20if=20(logger.isDebugEnable?=
 =?UTF-8?q?d())=20=E9=98=B2=E6=AD=A2message.toString=E6=AF=8F=E6=AC=A1?=
 =?UTF-8?q?=E9=83=BD=E4=BC=9A=E8=A2=AB=E8=BF=90=E8=A1=8C=EF=BC=8Cmessage?=
 =?UTF-8?q?=E8=BF=87=E5=A4=A7=E4=BC=9A=E5=8D=A1cpu?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../otter/canal/kafka/producer/CanalKafkaProducer.java      | 6 ++++--
 kafka/src/main/resources/kafka.yml                          | 4 ++--
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/kafka/src/main/java/com/alibaba/otter/canal/kafka/producer/CanalKafkaProducer.java b/kafka/src/main/java/com/alibaba/otter/canal/kafka/producer/CanalKafkaProducer.java
index 4543aac1..0bb15308 100644
--- a/kafka/src/main/java/com/alibaba/otter/canal/kafka/producer/CanalKafkaProducer.java
+++ b/kafka/src/main/java/com/alibaba/otter/canal/kafka/producer/CanalKafkaProducer.java
@@ -21,7 +21,7 @@ import com.alibaba.otter.canal.protocol.Message;
  */
 public class CanalKafkaProducer {
 
-    private static final Logger       logger = LoggerFactory.getLogger(CanalKafkaProducer.class);
+    private static final Logger logger = LoggerFactory.getLogger(CanalKafkaProducer.class);
 
     private Producer<String, Message> producer;
 
@@ -83,6 +83,8 @@ public class CanalKafkaProducer {
             record = new ProducerRecord<String, Message>(topic.getTopic(), message);
         }
         producer.send(record);
-        logger.debug("send message to kafka topic: {} \n {}", topic.getTopic(), message.toString());
+        if (logger.isDebugEnabled()) {
+            logger.debug("send message to kafka topic: {} \n {}", topic.getTopic(), message.toString());
+        }
     }
 }
diff --git a/kafka/src/main/resources/kafka.yml b/kafka/src/main/resources/kafka.yml
index d6ccc51a..2729fc27 100644
--- a/kafka/src/main/resources/kafka.yml
+++ b/kafka/src/main/resources/kafka.yml
@@ -3,7 +3,7 @@ retries: 0
 batchSize: 16384
 lingerMs: 1
 bufferMemory: 33554432
-# canal的批次大小，单位 k
+# canal的批次大小，单位 k，量大建议改为1M
 canalBatchSize: 50
 filterTransactionEntry: true
 
@@ -13,7 +13,7 @@ canalDestinations:
     partition:
     # 一个destination可以对应多个topic
 #    topics:
-#      - topics: example
+#      - topic: example
 #        partition: