7.1.1.1 Kafka 引擎集成

文档摘要

7.1.1.1 Kafka 引擎集成当 Kafka 消费者在 ClickHouse 中“静默失联”：一个被忽略的 offset 提交陷阱与实时性保障的终极解法你有没有遇到过这样的场景？凌晨两点，监控告警突然炸开——数据延迟飙升至 12 分钟；运维同事火速登录集群，发现 Kafka 表还在消费，能查出新数据，但下游物化视图（Materialized View）却像被冻住了一样，整整十分钟没有新记录写入；重启消费进程？没用。删表重建？三分钟后又卡住。日志里既没有 ERROR，也没有 WARN，只有几行轻描淡写的：“Offset committed for partition 3 at offset 1894721”。一切看起来都“正常”——可业务方的看板上，订单漏单率正以每秒 0.