上海 java jobs (salary & requirements)

岗位职责
1. 基于 Java 技术栈进行大数据实时计算相关系统的设计、开发、测试与上线，核心负责基于 Flink 的实时数据处理链路搭建与优化；
2. 负责 Kafka 集群的日常运维、topic 规划、分区优化、消息积压处理、吞吐量调优，保障消息传输的高可用、高可靠；
3. 参与需求评审，将业务需求转化为技术方案，基于 Flink 实现数据清洗、聚合、关联、CEP 复杂事件处理等核心业务逻辑；
4. 优化 Flink 作业的资源配置、并行度、状态后端checkpoint/savepoint
策略，解决数据延迟、数据一致性、作业重启等问题；
5. 对接上下游系统，设计基于 Kafka 的消息收发方案，适配不同数据源
（MySQL/Redis/日志）与下游存储（HDFS/HBase/Doris）的数据转；
任职要求
1. 计算机相关专业，3 年及以上 Java 后端开发经验，1 年及以上 Flink+Kafka
大数据实时计算项目实战经验；
2. 精通 Java 基础语法、集合框架、并发编程、IO/NIO，熟悉 SpringBoot、
SpringCloud 等微服务框架，具备扎实的后端开发功底；3. 精通 Flink 核心原理与应用，熟练使用 Flink DataStream/Table API，掌握
状态管理、窗口函数、CEP、分流合流等核心功能，能独立完成 Flink 作业开发与调优；
4. 精通 Kafka 核心机制，熟悉生产者/消费者原理、分区策略、副本机制、幂等性/事务消息、消费者组管理，能独立进行 Kafka 集群问题排查与性能调优；
5. 熟悉大数据生态相关组件（Hadoop/Hive/Doris/Redis 等），了解数据同步工具（Canal/MaxWell），具备端到端数据链路设计能力；
6. 具备良好的问题排查能力，能快速定位并解决线上 Flink 作业异常、Kafka消息积压/丢失、数据一致性等问题；
7. 熟悉 BES/华为 MRS 等信创组件优先。
3. 精通 Flink 核心原理与应用，熟练使用 Flink DataStream/Table API，掌握状态管理、窗口函数、CEP、分流合流等核心功能，能独立完成 Flink 作业开发与调优；
4. 精通 Kafka 核心机制，熟悉生产者/消费者原理、分区策略、副本机制、幂等性/事务消息、消费者组管理，能独立进行 Kafka 集群问题排查与性能调优；
5. 熟悉大数据生态相关组件（Hadoop/Hive/Doris/Redis 等），了解数据同步工具（Canal/MaxWell），具备端到端数据链路设计能力；
6. 具备良好的问题排查能力，能快速定位并解决线上 Flink 作业异常、Kafka消息积压/丢失、数据一致性等问题；
7. 熟悉 BES/华为 MRS 等信创组件优先。
项目: 天梯系统信创改造上云项目