Java开发工程师（Kafka方向）

岗位职责
1. 基于Apache Kafka进行深度定制开发，优化消息队列的高吞吐、低延迟及稳定性，满足亿级数据量场景下的性能需求；
2. 参与Kafka核心模块的架构设计与实现，包括但不限于分区管理、副本同步、内存池优化、多线程任务调度等；
3. 解决高并发、分布式环境下的复杂问题，如数据一致性、容错机制、资源争用等；
4. 设计并实现Kafka与大数据生态（如Flink、Spark、Hadoop）的高效集成方案；
5. 编写核心模块的单元测试与压测用例，保障系统可靠性；
6. 指导团队成员完成技术方案设计，推动代码质量与开发效率提升。
任职要求
开发能力：
5年以上Java开发经验，精通JVM原理、多线程编程及并发工具类（如ConcurrentHashMap、AtomicXXX、线程池等）；
熟悉Kafka源码及核心机制（分区、ISR、Leader选举、零拷贝等），有Kafka性能调优或二次开发经验；
精通内存管理，熟悉Kafka的内存池配置（如buffer.memory、message.max.bytes）及JVM内存优化策略；
掌握分布式系统设计，熟悉CAP理论、共识算法（如Raft）及分布式一致性实现；
技术深度：
熟悉Kafka与大数据生态系统的集成（如与Flink/Spark的流处理对接）；
有大规模消息队列部署经验，能针对高吞吐场景设计分区策略、副本机制及故障恢复方案；
熟悉操作系统底层原理（如IO模型、页缓存、文件句柄管理）；
工程素养：
精通Linux环境下的性能分析工具（如perf、strace、jstack、jstat）；
熟悉微服务架构及常见中间件（如Redis、Docker/K8s）；
具备优秀的代码能力，熟悉设计模式与工程规范，有大型系统开发经验。
加分项：
有Kafka社区贡献或开源项目经验；
熟悉C/C++，能参与Kafka底层性能优化（如JNI模块开发）；
熟悉云原生架构，有Serverless或容器化部署经验；
对流处理（Kafka Streams/Flink）或实时计算有深入实践。