From f9fec7bddfcb51e5c285b04219d53b19e9123480 Mon Sep 17 00:00:00 2001 From: agapple Date: Mon, 14 Oct 2019 14:59:08 +0800 Subject: [PATCH] Updated Canal Kafka RocketMQ QuickStart (markdown) --- Canal-Kafka-RocketMQ-QuickStart.md | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index a9185df..caed6a0 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/Canal-Kafka-RocketMQ-QuickStart.md @@ -156,6 +156,22 @@ binlog本身是有序的，写入到mq之后如何保障顺序是很多人会比 * 单topic、多topic的多分区，如果用户选择的是指定table的方式，那和第二部分一样，保障的是表级别的顺序性(存在热点表写入分区的性能问题)，如果用户选择的是指定pk hash的方式，那只能保障的是一个pk的多次binlog顺序性 ** pk hash的方式需要业务权衡，这里性能会最好，但如果业务上有pk变更或者对多pk数据有顺序性依赖，就会产生业务处理错乱的情况. 如果有pk变更，pk变更前和变更后的值会落在不同的分区里，业务消费就会有先后顺序的问题，需要注意 +## MQ发送性能数据 +1.1.5版本可以在5k~50k左右，具体可参考：[[Canal-MQ-Performance]] + +## 阿里云RocketMQ对接参数 +``` +# 配置ak/sk +canal.aliyun.accessKey = XXX +canal.aliyun.secretKey = XXX +# 配置topic +canal.mq.accessChannel = cloud +canal.mq.servers = 内网接入点 +canal.mq.producerGroup = GID_**group（在后台创建） +canal.mq.namespace = rocketmq实例id +canal.mq.topic=（在后台创建） +``` + ### 3.4 启动 ``` cd /usr/local/canal/