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

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

Browse Source
This commit is contained in:
mcy
2018-08-15 14:26:55 +08:00
parent feb2af060f
commit 4776552605
2 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
kafka/src/main/java/com/alibaba/otter/canal/kafka/producer/CanalKafkaProducer.java
View File

@@ -21,7 +21,7 @@ import com.alibaba.otter.canal.protocol.Message;
*/ */
public class CanalKafkaProducer { 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; private Producer<String, Message> producer;
@@ -83,6 +83,8 @@ public class CanalKafkaProducer {
record = new ProducerRecord<String, Message>(topic.getTopic(), message); record = new ProducerRecord<String, Message>(topic.getTopic(), message);
} }
producer.send(record); 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());
}
} }
} }

4
kafka/src/main/resources/kafka.yml
View File

@@ -3,7 +3,7 @@ retries: 0
batchSize: 16384 batchSize: 16384
lingerMs: 1 lingerMs: 1
bufferMemory: 33554432 bufferMemory: 33554432
# canal的批次大小，单位 k # canal的批次大小，单位 k，量大建议改为1M
canalBatchSize: 50 canalBatchSize: 50
filterTransactionEntry: true filterTransactionEntry: true
@@ -13,7 +13,7 @@ canalDestinations:
partition: partition:
# 一个destination可以对应多个topic # 一个destination可以对应多个topic
# topics: # topics:
# - topics: example # - topic: example
# partition: # partition: