公司动态
【TDengine】TDengine 是否支持 Flink CDC 或 Kafka Connect Sink?
TDengine 是否支持 Flink CDC 或 Kafka Connect Sink?—— 工业 IoT 实时数据管道深度集成指南问题原文:“TDengine 是否支持 Flink CDC 或 Kafka Connect Sink?”解析范围:本文聚焦于TDengine 3.4.x 社区版下,Flink CDC 与 Kafka Connect Sink 的官方/社区支持现状、实现原理、生产级配置、性能调优及在千万级工业 IoT 设备监控系统中的落地实践。内容适用于具备 Flink/Kafka/ClickHouse 经验但首次接触 TDengine 的中高级工程师。一、引子:工业 IoT 平台因数据管道断裂导致 P0 事故2025 年某大型制造企业的设备健康监测平台上线后遭遇严重数据延迟:原本秒级更新的设备状态,在 TDengine 中延迟高达 10 分钟。根因竟是团队自行开发的Kafka 到 TDengine 的简易消费者存在两个致命缺陷:未处理乱序数据:设备网络抖动导致消息乱序,写入失败后静默丢弃单线程消费:10万