Confluent 首席架构师万字剖析 Apache Fluss(三):湖流一体
原文:https://jack-vanlightly.com/blog/2025/9/2/understanding-apache-fluss
作者:Jack Vanlightly
翻译:Wayne Wang@腾讯
译注:Jack Vanlightly 是一位专注于数据系统底层架构的知名技术博主,他的文章以篇幅长、细节丰富而闻名。目前 Jack 就职于 Confluent,担任首席技术架构师,因此这篇 Fluss 深度分析文章,具备一定的客观参考意义。译文拆成了三篇文章,本文是第二篇。
SaaS云医院HIS系统源码,运行稳定的区域HIS系统
一套SaaS架构的Java版云HIS系统源码,支持电子病历四级应用。采用前后端分离技术,前端基于Angular,后端使用SpringBoot+MyBatisPlus,结合Redis、RabbitMQ、XXL-JOB等主流组件。
获取商品券后价接口设计与实现
电商券后价计算接口,支持商品页、购物车等多场景实时定价。规范入参出参,结合缓存、分布式锁与批量处理,保障高性能与一致性。核心算法精准叠加优惠,辅以安全校验与监控体系,已支撑12000+ QPS,平均响应78ms。
《聊聊分布式》BASE理论 分布式系统可用性与一致性的工程平衡艺术
BASE理论是对CAP定理中可用性与分区容错性的实践延伸,通过“基本可用、软状态、最终一致性”三大核心,解决分布式系统中ACID模型的性能瓶颈。它以业务为导向,在保证系统高可用的同时,合理放宽强一致性要求,并借助补偿机制、消息队列等技术实现数据最终一致,广泛应用于电商、社交、外卖等大规模互联网场景。
Linux下安装Kafka 3.9.1
本文介绍Kafka 3.9.1版本的安装与配置,包括通过ZooKeeper或KRaft模式启动Kafka。涵盖环境变量设置、日志路径修改、集群UUID生成、存储格式化及服务启停操作,适用于Linux环境下的部署实践。
常见面试题24
MQ死信队列用于处理消费失败或过期消息,通过死信交换机转发至指定队列,实现延迟处理。结合TTL可构建延迟队列。为防重复消费,可用去重表记录已处理消息。消息积压可通过并发消费、多线程、设置TTL和队列长度限制缓解,消费失败可转入死信队列避免阻塞。RabbitMQ支持简单、工作、广播、定向、主题五种消息模式。Elasticsearch正向索引以文档ID为主键,记录词位置,适合按文档查词,但检索效率低。
交易关闭自动处理接口
本文详解如何构建高效可靠的交易关闭自动处理接口,涵盖需求分析、事件驱动架构设计、Python实现示例及性能优化策略,助力提升电商、支付系统自动化水平,支持高并发、低延迟与容错处理。