From d0b1dc4869f52f3c5ac5e61b3c254677c40751e2 Mon Sep 17 00:00:00 2001 From: agapple Date: Sun, 28 Oct 2018 21:16:53 +0800 Subject: [PATCH] Updated Canal Kafka RocketMQ QuickStart (markdown) --- Canal-Kafka-RocketMQ-QuickStart.md | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index d3c0b55..f536019 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/Canal-Kafka-RocketMQ-QuickStart.md @@ -99,8 +99,7 @@ canalDestinations: | producerGroup | kafa无意义
rocketMQ为ProducerGroup名 | Canal-Producer | | canalBatchSize | 获取canal数据的批次大小 | 50 | | canalGetTimeout | 获取canal数据的超时时间 | 100 | -| flatMessage | 是否为json格式
如果设置为false,对应MQ收到的消息为protobuf格式
需要通过CanalMessageDeserializer进行解码 | -true | +| flatMessage | 是否为json格式
如果设置为false,对应MQ收到的消息为protobuf格式
需要通过CanalMessageDeserializer进行解码 | true | | CanalDestinations | 通道定义,父级目录 | -- | | CanalDestination | 通道名称 | 无 | | topic | mq里的topic名 | 无 |