canal server对性能影响最大的参数

[lwd-coding]

Question

最近做分库分表，需要同步几十张亿级表，发现canal.mq.canalBatchSize 这个参数对kafka写入影响最大。查看源码发现canal会通过主动控制flush来保证当前批次发送成功从而进行位点ack；所以在没调大canal.mq.canalBatchSize 的前提下你去调整kafka相关参数影响都不太明显