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)

agapple
2018-10-28 20:45:52 +08:00
parent a3664484a2
commit f2d66a2237
1 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
Canal-Kafka-RocketMQ-QuickStart.md

@@ -93,14 +93,17 @@ canalDestinations:
# #库名.表名: 唯一主键 # #库名.表名: 唯一主键
# mytest.person: id # mytest.person: id
``` ```
参数说明
``` ## mq.yml参数说明
servers: 对应 kafka的 `ProducerConfig.BOOTSTRAP_SERVERS_CONFIG`
retries: 对应kafka的`ProducerConfig.RETRIES_CONFIG` | 参数名 | 参数说明 | 默认值 |
batchSize: 对应kafka的`ProducerConfig.BATCH_SIZE_CONFIG` |-------|-----------|-------|
lingerMs: 对应kafka的`ProducerConfig.LINGER_MS_CONFIG` | servers | 对应 kafka的 `ProducerConfig.BOOTSTRAP_SERVERS_CONFIG` | |
bufferMemory: 对应kafka的`ProducerConfig.BUFFER_MEMORY_CONFIG` | retries | 对应kafka的`ProducerConfig.RETRIES_CONFIG` | |
``` | batchSize | 对应kafka的`ProducerConfig.BATCH_SIZE_CONFIG` | |
| lingerMs | 对应kafka的`ProducerConfig.LINGER_MS_CONFIG` | |
| bufferMemory | 对应kafka的`ProducerConfig.BUFFER_MEMORY_CONFIG` | |
### 3.4 启动 ### 3.4 启动
``` ```
cd /usr/local/canal/ cd /usr/local/canal/