流处理技能包

用于构建Python Kafka生产者或消费者，集成Schema Registry，迁移至模式序列化，或为Confluent Cloud、Docker及WarpStream搭建项目并优化配置。

在 Confluent Cloud 上使用 Flink SQL 将客户订单流与客户表关联，生成包含忠诚度等级的富化数据流。

在 Confluent Cloud 上构建端到端 CDC 管道，通过 Debezium、Flink 和 Tableflow 将数据库变更同步至 Iceberg 或 Delta Lake。

评估并规划从 AWS MSK 到 Confluent Cloud 的迁移，涵盖集群配置、Cluster Linking 及切换验证。

为 Confluent Cloud、Kafka、Flink 等产品创建专用技能。适用于构建数据增强或 CDC 等工作流，而非直接使用产品功能。

编写和调试运行于 Confluent Cloud 的 Flink SQL，严格区分 CC 与 Apache Flink OSS 方言差异。

构建并部署 Apache Flink Java 用户自定义函数，支持标量、表及处理表函数，适用于 Kafka 流处理场景。

为 Confluent Cloud 或 Platform 提供基于延迟、吞吐量等优先级的 Kafka 只读配置分析与调优建议，涵盖权衡与验证方案。

用于在现有应用中集成 Kafka 客户端或搭建基于 Maven/Gradle 的 Java Kafka 项目，支持 Confluent Cloud、Docker 及 WarpStream。

用于构建、调试和优化 Kafka Streams 流处理应用。支持拓扑设计、状态存储管理及 WarpStream 配置调优，涵盖 KStream/KTable 及常见故障排查。

扫描项目识别 Kafka 应用，提取数据模型中的 Schema，标记 PII 字段，生成用于 Confluent Schema Registry 注册的 Terraform 代码及迁移报告。