Canal + Kafka经验

canal中写入kafka的BUG kafka的默认最大消息大小是1M, canal做者也知道这个事, 因此往canal扔消息的时候, 会先作一个判断, 若是消息大小>1M, 会报错 但关键是他报错说的要把kafka的配置改大, 其实是本身作了阉割, 怨不得kafka, 我横来竖去改了n遍kafka的配置也没用 目前我作的是修改了canal的源码:(GITHUB上最新版源码已经加上了这个配置)ja
相关文章
相关标签/搜索