北京 java jobs (salary & requirements)

岗位职责：
1. 负责工业数据采集与接入层开发：设计和实现高可靠的设备接入框架，负责机床（CNC）数据通过MQTT协议上报至云端EMQX集群的链路优化，保障海量设备数据的安全、稳定上报。
2. 构建实时流式数据处理管道：基于Flink进行实时数据清洗、转换与计算，处理通过Kafka缓存的高吞吐量数据，为上层业务提供低延迟的指标输出。
3. 数据存储架构设计与优化：根据时序数据和业务数据的不同特性，设计并实现数据在TDengine（时序数据库） 与PostgreSQL（关系型数据库） 中的混合存储方案，负责超级表模型设计、SQL性能调优及集群维护。
4. 后端微服务开发与维护：使用Spring Boot/Cloud框架开发设备管理、告警中心、数据可视化API等核心业务模块，保障系统的高并发与高可用性。
5. 技术攻关与性能调优：深入解决JVM性能瓶颈、Kafka消息积压、Flink任务Checkpoint失败等疑难问题，持续优化端到端的数据处理延迟。
任职要求：
技术栈硬性要求：
1.
Java基础：精通Java编程，必须有基于Java 17/21 LTS版本的实际项目开发经验，熟悉虚拟线程（VirtualThreads）等新特性者优先；
2. 熟悉数据结构，如快速排序、二叉树遍历、平衡二叉树、红黑树等，常用设计模式，如：工厂模式、适配器模式、观察者模式、单例模式等；
3. 大数据生态：熟悉Kafka消息队列原理，具备Flink实时流处理开发经验，能够独立编写Flink作业处理数据；
4. 数据库能力：熟悉TDengine（时序数据库）或类似时序库（如InfluxDB）的应用；
5. 精通PostgreSQL或MySQL等关系型数据库的SQL优化与高可用架构设计；
工业/物联网经验（加分项）：
1. 精通MQTT协议，有EMQX等MQTT Broker的实际运维或二次开发经验；
2. 了解工业物联网常见协议（如Modbus、OPC-UA）；