mirror of
https://github.com/alibaba/canal.git
synced 2026-11-04 00:30:15 +08:00
Updated Canal Kafka RocketMQ QuickStart (markdown)
@@ -96,7 +96,7 @@ canalDestinations:
|
||||
| batchSize | kafka为`ProducerConfig.BATCH_SIZE_CONFIG` <br> rocketMQ无意义 | 16384 |
|
||||
| lingerMs | kafka为`ProducerConfig.LINGER_MS_CONFIG` <br> rocketMQ无意义 | 1 |
|
||||
| bufferMemory | kafka为`ProducerConfig.BUFFER_MEMORY_CONFIG` <br> rocketMQ无意义 | 33554432 |
|
||||
| producerGroup | kafa无意义 <br> rocketMQ为ProducerGroup名 | Canal-Producer |
|
||||
| producerGroup | kafka无意义 <br> rocketMQ为ProducerGroup名 | Canal-Producer |
|
||||
| canalBatchSize | 获取canal数据的批次大小 | 50 |
|
||||
| canalGetTimeout | 获取canal数据的超时时间 | 100 |
|
||||
| flatMessage | 是否为json格式 <br> 如果设置为false,对应MQ收到的消息为protobuf格式<br>需要通过CanalMessageDeserializer进行解码 | true |
|
||||
|
||||
Reference in New Issue
Block a user