Make MQ Great Again！COSCon‘25 x Pulsar Developer Day 2025 精彩回顾-平芜编程栈

12 月 6-7 日，COSCon'25 第十届中国开源年会在北京市海淀区丽亭华苑酒店举办。本届大会以「众智开源 Open Source, Open Intelligence」为主题，汇聚全球开源力量，共话技术与生态。

作为 COSCon'25 的同场活动，Pulsar Developer Day 2025 汇聚了来自小红书、中原银行、360、中电金信、谙流科技及 StreamNative 等企业的技术专家与 Pulsar 社区爱好者，围绕 Pulsar 的实践落地、技术创新与生态演进展开深度分享，为行业呈现了一场兼具深度与实用性的技术盛宴，推动 Pulsar 社区在开源协作中持续成长。

小红书中间件团队的卢世吉、段林林、孟祥迎、张安伟四位工程师带来了题为《小红书在线 MQ 的特色实践》的分享。他们从架构设计、SDK 治理、生态贡献三大维度展开，详解了小红书 MQ 的三层架构 —— 运维管控层、Client SDK+Proxy、MQ 引擎，其中运维管控层通过统一 UI 实现限流、消息查询等多维度操作，保障服务可靠性；Events Client SDK 支持多语言接入，通过 Proxy 层实现 MQ 引擎的灵活治理与平滑迁移。针对 SDK 接入混乱的痛点，小红书通过改造 NameServer 收口新增接入、定时扫描改造存量系统的方式，半年内将标准化覆盖率从 30% 提升至 70%。此外，团队还分享了在 pulsar-java-contrib 中的技术贡献，包括 RPC 框架、扩展事务 API、PullConsumer 等新特性，为 Pulsar 生态注入新活力。

中原银行中间件团队负责人王东分享了《中原银行开源消息中间件的落地实践》。中原银行作为河南省属法人银行，在业务扩张中面临第一代 RabbitMQ 的脑裂风险高、扩展能力弱、性能瓶颈等问题。基于存算分离、云原生架构、高稳定性等核心优势，银行选择 Pulsar 作为第二代消息队列，并进行深度定制改造，构建了包含客户端 SDK、Pulsar Operator、集群管理端等模块的定制化体系。在部署层面，通过双中心与跨中心部署保障业务连续性，单节点故障可秒级切换。未来，中原银行将迈向智能化消息平台，打造智能运维助手、诊断分析工具，并探索 Pulsar 在 AI 多 Agent 通信场景的应用，为金融业务数字化转型提供更强大支撑。

360 消息队列研发王任义做了题为《Apache Pulsar在360消息队列PaaS平台上的探索与实践》的分享，聚焦 Pulsar 在企业级 PaaS 平台的探索与实践。王任义介绍，360 将 Pulsar 定位为在线业务核心消息队列，与 Kafka 形成离线与在线场景的互补。通过性能压测验证，Pulsar 在单分区 topic 下实现 0.3ms 低延迟与 150 万条 / 秒高吞吐，核心瓶颈集中在 Bookie 数据持久化。在 PaaS 平台建设中，360 依托 Pulsar 的弹性伸缩与原生多租户能力，实现资源组隔离，支持小流量共享、大流量独占的灵活部署模式。通过 ServerlessManager 实时监控指标，实现资源动态扩缩容与故障无感切换，最终使磁盘利用率从 10% 提升至 50%，用户成本降低 45 倍。未来，360 计划以 Pulsar 为核心构建统一事件总线，对接数据库 CDC 与大数据生态，拓展更多应用场景。

谙流科技 Kafka on Pulsar 研发负责人陶久明分享了《谙流科技在 Kafka on Pulsar 之上的探索》，介绍了 KoP（Kafka on Pulsar）的技术原理、核心优势与产品化实践。KoP 通过协议 handler 实现 Kafka 与 Pulsar 的无缝兼容，在 Topic、消息 ID、偏移量管理等方面建立映射关系，继承了 Pulsar 的多租户、云原生特性。其核心优势体现在秒级扩容、无数据迁移、资源利用率高、低延迟等方面，通过分片模型与存储优化，实现写入吞吐与存储效率的双重提升。在产品化建设中，谙流科技通过混沌测试、单元测试等多维度保障稳定性，修复了堆外内存溢出、元数据异常等关键问题，目前集群已支持每日 PB 级数据处理，峰值吞吐达 39GB/s。未来，团队将引入 Oxia 去 Zookeeper，适配公有云存储，进一步提升产品性能与灵活性。

StreamNative 高级软件工程师赵强带来了题为《下一代元数据平台： Oxia 实践》的分享。针对流处理系统中元数据规模大、更新频繁的挑战，Oxia 采用 “控制层 + 数据层” 的物理架构与分片逻辑架构，基于 LSM Tree 实现高写入吞吐，通过法定人数写入保障数据强一致性。Oxia 提供标准 KV 接口、版本控制、自动会话管理、通知机制等核心能力，可满足云原生场景下的元数据存储需求。在运维层面，Oxia 支持分片负载均衡、leader 均匀分布、故障自动恢复等自动化能力，还可通过亲和性配置优化资源调度，未来将支持分片自动拆分与合并。作为 Pulsar 生态的重要补充，Oxia 致力于成为更可扩展、更稳健的云原生元数据系统，为分布式应用提供底层支撑。

中电金信大数据开发刘思楠详细拆解了 Apache Pulsar 延迟消息的实现机制与混合架构演进。Pulsar 原生支持延迟可见模式，提供 InMemory 与 Bucket 两种实现，其中 Bucket 模式通过将索引卸载到 BookKeeper，支持超大规模延迟消息场景，核心流程包括消息路由、固化刷盘、索引加载等关键步骤。但原生实现存在性能瓶颈与功能缺失等问题，为此，引入外部延迟消息服务 Chronos，其基于 RocksDB 的 KV 存储、秒级扫描推送机制，实现高效的延迟消息调。Pulsar 与 Chronos 的混合架构，支持客户端与 Broker 侧两种集成方式，兼顾原生优势与扩展能力。该方案为延迟消息场景提供了更灵活的解决方案，也为 Pulsar 功能拓展提供了新思路。

现场还颁发了社区最佳实践及贡献者奖项。

Pulsar Developer Day 2025 汇聚了多个领域的技术前沿实践，从企业落地案例到核心技术创新，从性能优化到生态拓展，全方位展现了 Apache Pulsar 的强大生命力与广阔应用前景。

展望未来，随着云原生、大数据、AI 等技术的深度融合，消息中间件将面临更多复杂场景的挑战。Pulsar 社区将持续秉持开源理念，积极拥抱更多场景，在性能优化、功能拓展、生态兼容等方面持续发力，推动技术创新与实践落地。我们也期待更多企业与开发者加入 Pulsar 生态，共同探索消息中间件的无限可能，让 MQ 技术在开源协作中不断突破，为分布式智能系统的稳定、高效运行提供更坚实的支撑。

Apache Pulsar 作为一个高性能、分布式的发布-订阅消息系统，正在全球范围内获得越来越多的关注和应用。如果你对分布式系统、消息队列或流处理感兴趣，欢迎加入我们！

Github:

https://github.com/apache/pulsar

扫码加入 Pulsar 社区交流群

最佳实践

互联网

腾讯BiFang | 腾讯云 | 微信 | 腾讯 | BIGO | 360 | 滴滴 | 腾讯互娱 | 腾讯游戏 | vivo | 科大讯飞 | 新浪微博 | 金山云 | STICORP | 雅虎日本 | Nutanix Beam | 智联招聘 | 达达 | 小红书

金融/计费

腾讯计费 | 平安证券 | 拉卡拉 | Qraft | 甜橙金融

电商

Flipkart | 谊品生鲜 | Narvar | Iterable

机器学习