Baike.dev
All toolsAI codingTrendingOpen sourceNewsSubmit
Log in
Back to tool/Back to issues
#5431·canal

使用docker-compose设置canal.mq.flatMessage = true时,kafka无法收到消息

Author: ArkoBAKACreated Apr 14, 2025Updated Sep 6, 2026

Canal 版本: v1.1.8 MySQL 版本: 8.4.4 部署方式: Docker Compose

在使用 Canal 推送 binlog 到 Kafka 的过程中,设置 canal.mq.flatMessage=true 后,Kafka 中没有收到任何消息,也没有任何报错或异常日志。 确认 Canal 正常连接 MySQL,且能读取 binlog 日志(从 meta.log 中可见位点持续推进),Kafka topic 也已创建并可消费。 但只有在将 flatMessage=false 时,Kafka 才能正常接收到消息。

日志中完全没有任何提示 flatMessage 模式为何无法生效,浪费大量时间排查。 建议至少在 flatMessage 模式未生效时输出提示,或补充相关文档说明是否有其它依赖或前提条件。

Source: alibaba/canal

View original on GitHubView discussion on GitHub