崗位職責： 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等信創組件優先。