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名 | 无 |