加上 if (logger.isDebugEnabled()) 防止message.toString每次都会被运行，message过大会卡cpu

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());
+        }
     }
 }

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: