用途：该技能提供 Confluent ksqlDB 的专家知识，用于在 Kafka 主题上以类 SQL 查询构建实时流处理应用，适合需要流处理、实时分析或对 Kafka 做 SQL 查询的场景。
主要能力：区分流（无界、仅追加、每行是新事件）与表（可变、按键保留最新状态、底层为压缩主题）；支持流式查询（EMIT CHANGES 持续输出）、物化视图（CREATE TABLE AS 预计算聚合）、拉取查询（点查当前状态，无 EMIT CHANGES）。支持流-流、流-表、表-表连接；窗口类型包括滚动（TUMBLING）、跳跃（HOPPING）、会话（SESSION），并可用 GRACE PERIOD 处理迟到事件。常见模式含过滤、流表连接富化、实时聚合、异常检测（HAVING 阈值）、CDC 变更捕获。
使用方式：以 SQL 语句定义流/表并指定 kafka_topic、value_format 等 WITH 参数；聚合需配合窗口；连接需按键共分区，必要时用 PARTITION BY 重分区。
限制与注意：非窗口聚合可能内存无界并导致查询超时；货币等精确值应使用 DECIMAL 而非 DOUBLE；表需显式主键才能连接；可通过 retention_ms 设置保留策略。具体版本、部署与收费信息暂未提供。