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
2018-12-28 16:14:27 +08:00
parent d7caf8ef8a
commit 1bfcf20ea3
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
Canal-Kafka-RocketMQ-QuickStart.md

@@ -48,6 +48,9 @@ canal.instance.dbPassword = canal
...
# mq config
canal.mq.topic=example
# 针对库名或者表名发送动态topic, 表达式如果只有库名则匹配库名的数据都会发送到对应名称topic
# 如果是库名.表名则会发送到以库名.表名为名称的topic
#canal.mq.dynamicTopic=mytest,.*,mytest.user,mytest\\..*,.*\\..*
canal.mq.partition=0
# hash partition config
#canal.mq.partitionsNum=3