崗位職責
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 等信創組件優先。
項目: 天梯系統信創改造上云項目