岗位职责
1. 基于 Java 技术栈构建高可用、高性能的实时/离线数据处理系统,支撑业务数据流转与分析需求; 2. 负责 Kafka、MQTT 等消息中间件的集群运维、消息流转设计及峰值流量处理; 3. 运⽤ Flink、Spark 实现实时计算逻辑开发,包括数据清洗、聚合、关联等核⼼业务场景; 4. 参与数据湖架构设计与优化,实现数据的统⼀存储、管理及高效查询; 5. 基于 TCP/IP 网络通信协议,处理跨系统数据传输、接口对接及⽹络问题排查; 6. 优化数据处理链路性能,解决数据延迟、数据一致性等核心问题。