diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index c672e27..3457b98 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/Canal-Kafka-RocketMQ-QuickStart.md @@ -106,7 +106,7 @@ canal.mq.transaction = false | canal.mq.canalBatchSize | 获取canal数据的批次大小 | 50 | | canal.mq.canalGetTimeout | 获取canal数据的超时时间 | 100 | | canal.mq.flatMessage | 是否为json格式
如果设置为false,对应MQ收到的消息为protobuf格式
需要通过CanalMessageDeserializer进行解码 | true | -| canal.mq.transaction | kafka消息投递是否使用事务, 主要针对flatMessage的异步发送和动态多topic消息投递进行事务控制来保持和canal binlog position的一致性, flatMessage模式下建议开启(需要kafka版本支持)。如果设置为true, flatMessage消息将会采用逐条同步的方式投递, 可能会产生消息丢失或者重复投递
rocketMQ无意义 | false | +| canal.mq.transaction | kafka消息投递是否使用事务, 主要针对flatMessage的异步发送和动态多topic消息投递进行事务控制来保持和canal binlog position的一致性, flatMessage模式下建议开启(需要kafka版本支持)。如果设置为false, flatMessage消息将会采用逐条同步的方式投递, 可能会产生消息丢失或者重复投递
rocketMQ无意义 | false | | --- | --- | --- | | canal.mq.topic | mq里的topic名 | 无 | | canal.mq.dynamicTopic | mq里的动态topic规则, 1.1.3版本支持 | 无 |