You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
23 lines
872 B
23 lines
872 B
# ...
|
|
# 可选项: tcp(默认), kafka, RocketMQ
|
|
canal.serverMode = kafka
|
|
# ...
|
|
# kafka/rocketmq 集群配置: 192.168.1.117:9092,192.168.1.118:9092,192.168.1.119:9092
|
|
canal.mq.servers = kafka:9092
|
|
canal.mq.retries = 0
|
|
# flagMessage模式下可以调大该值, 但不要超过MQ消息体大小上限
|
|
canal.mq.batchSize = 16384
|
|
canal.mq.maxRequestSize = 1048576
|
|
# flatMessage模式下请将该值改大, 建议50-200
|
|
canal.mq.lingerMs = 1
|
|
canal.mq.bufferMemory = 33554432
|
|
# Canal的batch size, 默认50K, 由于kafka最大消息体限制请勿超过1M(900K以下)
|
|
canal.mq.canalBatchSize = 50
|
|
# Canal get数据的超时时间, 单位: 毫秒, 空为不限超时
|
|
canal.mq.canalGetTimeout = 100
|
|
# 是否为flat json格式对象
|
|
canal.mq.flatMessage = false
|
|
canal.mq.compressionType = none
|
|
canal.mq.acks = all
|
|
# kafka消息投递是否使用事务
|
|
canal.mq.transaction = false |