canal
canal copied to clipboard
Canal 1.1.7 无法抽取压缩的binlog至kafka
Question
服务启动后,可以在日志里看到读取到的mysql binlog名称,position,timestamp等信息,但是ZK的znode没有更新cursor信息,kafka中也没有数据写入。同样的实例配置可以正常抽取非压缩的binlog至kafka。 请问Canal需要做什么额外的解压缩配置吗
需要提供完整的复现参数,比如mysql的压缩参数,以及对应的binlog文件
mysql压缩参数为: set global binlog_transaction_compression=on; set global binlog_transaction_compression_level_zstd=3; bin-log.000021.txt