设置canal.mq.flatMessage=true时一直没有数据发送到Kafka
作者: zhuenjun创建于 2020年8月28日更新于 2026年9月3日
- canal.instance.master.address=192.168.2.49:3306
- canal.instance.dbUsername=root
- canal.instance.dbPassword=root
- canal.instance.connectionCharset=UTF-8
- canal.instance.tsdb.enable=true
- canal.instance.gtidon=false
- canal.instance.filter.regex=test.test,
- canal.mq.partition=0
- canal.serverMode=kafka
- canal.mq.servers=192.168.1.65:9092
- canal.mq.flatMessage=true
- canal.mq.retries=1
- canal.mq.batchSize=16384
- canal.mq.maxRequestSize=1048576
- canal.mq.lingerMs=50
- canal.mq.bufferMemory=33554432
- canal.mq.compressionType=none
- canal.mq.acks=all
- canal.mq.transaction=true
内容来源: alibaba/canal