diff --git a/Canal-Kafka-RocketMQ-QuickStart.md b/Canal-Kafka-RocketMQ-QuickStart.md index f536019..346ed70 100644 --- a/Canal-Kafka-RocketMQ-QuickStart.md +++ b/Canal-Kafka-RocketMQ-QuickStart.md @@ -96,7 +96,7 @@ canalDestinations: | batchSize | kafka为`ProducerConfig.BATCH_SIZE_CONFIG`
rocketMQ无意义 | 16384 | | lingerMs | kafka为`ProducerConfig.LINGER_MS_CONFIG`
rocketMQ无意义 | 1 | | bufferMemory | kafka为`ProducerConfig.BUFFER_MEMORY_CONFIG`
rocketMQ无意义 | 33554432 | -| producerGroup | kafa无意义
rocketMQ为ProducerGroup名 | Canal-Producer | +| producerGroup | kafka无意义
rocketMQ为ProducerGroup名 | Canal-Producer | | canalBatchSize | 获取canal数据的批次大小 | 50 | | canalGetTimeout | 获取canal数据的超时时间 | 100 | | flatMessage | 是否为json格式
如果设置为false,对应MQ收到的消息为protobuf格式
需要通过CanalMessageDeserializer进行解码 | true |