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

Updated Canal Kafka RocketMQ QuickStart (markdown)

rewerma
2019-03-25 19:22:42 +08:00
parent 607723fadb
commit e546cc8c31
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
Canal-Kafka-RocketMQ-QuickStart.md

@@ -76,8 +76,10 @@ canal.serverMode = kafka
# kafka/rocketmq 集群配置: 192.168.1.117:9092,192.168.1.118:9092,192.168.1.119:9092 # kafka/rocketmq 集群配置: 192.168.1.117:9092,192.168.1.118:9092,192.168.1.119:9092
canal.mq.servers = 127.0.0.1:6667 canal.mq.servers = 127.0.0.1:6667
canal.mq.retries = 0 canal.mq.retries = 0
# flagMessage模式下可以调大该值, 但不要超过MQ消息体大小上限
canal.mq.batchSize = 16384 canal.mq.batchSize = 16384
canal.mq.maxRequestSize = 1048576 canal.mq.maxRequestSize = 1048576
# flatMessage模式下请将该值改大, 建议50-200
canal.mq.lingerMs = 1 canal.mq.lingerMs = 1
canal.mq.bufferMemory = 33554432 canal.mq.bufferMemory = 33554432
# Canal的batch size, 默认50K, 由于kafka最大消息体限制请勿超过1M(900K以下) # Canal的batch size, 默认50K, 由于kafka最大消息体限制请勿超过1M(900K以下)