CommunityOverCode 是 Apache 软件基金会（ASF）的官方全球系列大会，其前身为 ApacheCon。每年的 CommunityOverCode Asia 都吸引着来自全球各个层次的参与者、社区共同探索 "明天的技术"。2025年7月25日至27日， CommunityOverCode Asia 2025 将在北京举办，带来 Apache 项目的最新发展和新兴创新。
本次 CommunityOverCode Asia 2025 的 Messaging 专题，将给大家带来 Apache 社区建设和发展的最新资讯和前沿实践，现在就一起来看看吧！
专题介绍
伴随着云原生 Serverless、物联网、实时数据技术的规模化落地，事件驱动架构、事件流技术得以更广泛的应用，使得消息队列成为越来越重要的基础设施。今天在Apache生态中已经涌现了多个优秀的消息项目，包括：Apache Pulsar、Apache Kafka、Apache RocketMQ、Apache ActiveMQ、Apache Inlong 等等。
在这个主题中，你将了解到不同的消息系统如何基于自身的架构特点做出最优的技术演进方向，包括存算分离、Serverless、消息流一体等；也能学习各大厂商如何结合自身的行业特点、业务场景选择合适的消息技术，获得消息技术的最佳实践。
出品人
翟佳
Apache Pulsar & Apache BookKeeper PMC member，谙流科技的联合创始人兼 CEO。曾是 StreamNative 的联合创始人担任 CTO 和中国区负责人职务。硕士毕业于中国科学院计算技术研究所，之后加入 EMC，从事分布式、文件系统、流存储相关的设计和开发。主要从事开源项目 Apache BookKeeper 和 Apache Pulsar 的设计和开发工作，集中在消息和流存储方向。在分布式、存储、消息等领域有深厚的积累和经验，在相关领域先后获得中美专利 10 余项。
林清山
Apache RocketMQ 联合创始人& PMC member，阿里云消息产品线负责人，阿里云架构组中间件组长。十多年分布式中间件、消息队列研发经验，致力于消息、EDA、事件流处理、云原生等方向的探索和研究。
胡宗棠
中国移动云能力中心，中间件和大数据领域技术专家，移动云中间件/大数据团队负责人。8 年以上消息中间件内核开发和架构设计经历，从无到有参与移动云 RocketMQ、MQTT、Kafka 等多款主流消息中间件系列产品的内核架构和研发，作为技术嘉宾，曾多次参与 Apache Conf Aisa 2022/2023/2024 主论坛/分论坛、ApacheRocketMQ Summit/Meetup、云原生服务大会技术分享，开源项目实践经验丰富担任 Apache RocketMQ、Nacos、openEuler messagemiddleware sig 和 openMessaging 等开源社区的 Maintainer/Committer。信通院 2023 年《云计算开源标准突出贡献专家》，《2024 信通院 OSCAR 尖峰开源人物》，多个开源社区的开源先锋等荣誉。
议程亮点
7 月 25 日 14:00 17:15
演讲议题：Apache RocketMQ Eventbridge｜您的 GenAI 为何需要 EDA？
分享时间：7 月 25 日 14:0014:30
议题介绍：
如果您身处 AI 领域，EDA 为 LLM 和 AI Agent 提供的重要帮助不容忽视。本演讲将重点探讨 EDA 为 GenAI 带来的改变：
1. 通过实时 RAG，EDA 让您的 LLM 更加智能。
2. EDA 帮助您更好地使用 LLM。
3. 借助 MCP，EDA 赋能您的 Agent。
4. 为了增强多 Agent 能力，您应该关注 EDA。
此外，本演讲还将展示 Apache RocketMQ Eventbridge 在阿里云上在这些领域的实践和探索。
演讲嘉宾：
Lin Shen: Apache RocketMQ PMC
Apache RocketMQ PMC成员，阿里云 EventBridge 负责人，专注于 EDA 研究。
演讲议题：Apache Pulsar 在腾讯云上的高可用性最佳实践
分享时间：7 月 25 日 14:3015:00
议题介绍：Apache Pulsar 是一个云原生的分布式消息和流式传输平台。Apache Pulsar 采用存储与计算分离的架构，支持大型集群、多租户、百万级主题、跨区域数据复制、持久化存储、分层存储、高可扩展性等企业级及金融级服务。Apache Pulsar 提供统一的消费模型，同时支持消息队列和流式传输场景。它不仅能为队列场景提供企业级的读写服务质量和强一致性保证，还能为流式传输场景提供高吞吐量和低延迟。 Apache Pulsar 已在企业关键业务中落地，拥有丰富的应用场景。目前，腾讯云也已在生产实践中大规模应用 Apache Pulsar 近 5 年。在生产实践中，腾讯云对 Apache Pulsar 进行了一系列性能优化和稳定性增强，以确保用户在不同场景下系统能够稳定高效地运行。 本次演讲我们将重点讲解腾讯云上 Apache Pulsar 在高可用性方面的最佳实践，包括 Broker 集群和 Bookkeeper 集群的高可用性、Zookeeper 集群的高可用性以及跨集群的高可用性实践，希望能够为开发者提供一些参考。
演讲嘉宾：
Mingze Han｜tencent
毕业于武汉大学计算机专业。腾讯云高级研发工程师。开源社区爱好者。在美团和腾讯拥有超过 8 年的消息队列相关研发和运营经验。目前主要负责腾讯云 TDMQ for Pulsar 产品的核心部分。同时，我是 Apache Pulsar Contributor 和 RoP Maintenanceer。
演讲议题：使用 Apache Pulsar 构建高可靠订阅和推送服务｜挑战与最佳实践
分享时间：7 月 25 日 15:0015:30
议题介绍：分析华为云物联网基于 Apache Pulsar 构建订阅和推送服务的最佳实践。订阅和推送服务看似简单，实则涉及诸多架构决策。本演讲将深入探讨我们如何设计统一的推送服务架构，以确保海量数据分发的高可靠性和稳定性，从而帮助客户高效集成数据流，加速数字化转型。
演讲嘉宾：
Zhangjian He｜Huawei Cloud IoT Senior Engineer | Huawei Cloud Open Source Team Member
Apache BookKeeper&Apache ServiceComb PMC member、Apache Pulsar Committer，华为云工业软件平台云服务产品编码&开源负责人、华为云OSDT成员。
演讲议题：解密 Apache Kafka 的架构创新与多场景最佳实践
分享时间：7 月 25 日 15:4516:15
议题介绍：阿里云 Kafka 基于开源 Kafka 全面升级，融合弹性计算、高性能分布式文件存储和容器服务等云原生基础设施，实现高性能存储计算分离架构。云原生 Kafka 的快速恢复机制大幅降低 RTO，读写隔离机制则充分保障服务质量。低延迟、高吞吐量、极致弹性和便捷的运维能力，使云原生 Kafka 架构足以应对众多业务场景。本次演讲在详细讲解云原生 Kafka 高性能实现原理的同时，还将从车联网、人工智能等领域展现云原生 Kafka 的多场景最佳实践。
演讲嘉宾：
Fujian Zhao｜Alibaba Senior Software Engineer
2020 年 6 月毕业于东南大学，2020 年 7 月加入阿里巴巴。
演讲议题：Apache Pulsar 在大规模分区环境下的指标收集实践
分享时间：7 月 25 日 16:1516:45
议题介绍：Apache Pulsar 是一个高性能消息队列，支持海量 Topic，允许用户在单个集群内创建数十万甚至数百万个分区。指标是我们在生产环境中识别和诊断问题的关键工具。可观察性的有效性直接影响故障排除的速度。 在分区数量众多的场景下，启用 Topic 级指标可能会在短时间内生成大量指标字符串，从而导致严重的内存波动，并可能导致集群不稳定。 本次演讲将分享我们在此类高分区场景下收集指标的实践经验，并探讨如何在不影响在线内存稳定性的情况下最大限度地收集指标数据，从而实现高效的问题识别和系统监控。
演讲嘉宾：
Lin Lin｜Huawei, SDE expert, Middleware technology director
华为 SDE 专家，中间件技术总监，曾就职于腾讯、蚂蚁金服 专注于中间件和基础设施领域，拥有超过 10 年的相关经验，致力于打造高品质的基础设施 Apache Pulsar Committer & PMC 成员
演讲议题：Apache Pulsar 在小红书公司线上场景的探索与实践
分享时间：7 月 25 日 16:4517:15
议题介绍：本次分享将比较 Pulsar 与 RocketMQ 的特性，以及 Pulsar 在小红书线上场景中的实现方式（包括特性延迟、多活、压缩等），以及企业获得的实际收益。
演讲嘉宾：
卢世吉｜Apache BookKeeper PMC
小红书公司在线MQ负责人，Apache BookKeeper PMC，拥有5年MQ开发经验，致力于打造稳定可靠的基础组件。
Linlin Duan｜rednote
消息队列高级研发工程师。
Xiangying Meng ｜ Apache Pulsar PMC
小红书高级研发工程师，拥有 4 年 Apache Pulsar 内核研发与实践落地经验。曾就职于 StreamNative。专注于消息队列领域，持续探索其技术前沿与更多可能性。
7 月 26 日 14:00 17:45
演讲议题：腾讯云上的 Kafka：无缝迁移与灾难恢复
分享时间：7 月 26 日 14:0014:30
议题介绍：本次演讲将介绍如何将自建 Kafka 集群无缝迁移至腾讯云 CKafka 解决方案，无需关注迁移过程中生产消费应用的切换顺序。同时还将详细介绍腾讯云 CKafka 的故障容灾方案。
演讲嘉宾：
Shilin Lu｜Tencent Cloud Expert Engineer
毕业于天津大学软件工程专业，目前负责腾讯云 Kafka 内核开发与优化工作，拥有 7 年消息中间件开发运维经验。曾在腾讯、字节跳动等公司负责消息中间件研发，具备大规模集群运维经验。同时作为 Apache Kafka 和 RocketMQ 开源项目贡献者，积极参与开源社区建设。
演讲议题：构建云 MQTT 解决方案的经验教训
分享时间：7 月 26 日 14:3015:00
议题介绍：MQTT 已成为物联网 (IoT) 的事实标准，为汽车、制造、电信、石油天然气等行业的众多应用提供支持。
在腾讯云，我们开发了基于共享弹性流日志的稳健云 MQTT 解决方案。在本次演讲中，我们将分享开发过程中的关键见解和经验教训。我们将首先概述整体架构，重点介绍性能优化，并分享最佳实践。接下来，我们将深入探讨如何在共享日志之上实现 MQTT 协议——这种设计可扩展以支持其他消息传递协议。我们还将探讨动态扩展系统以支持数百万连接设备并保持高性能和可靠性的策略。最后，我们将讨论如何将存储和计算分离，并结合专用的 MQTT 负载均衡器，帮助我们降低总体拥有成本 (TCO)，并灵活高效地应对流量高峰。
演讲嘉宾：
Senze Zhang｜Apache RocketMQ Committer
Senze Zhang 是一位资深的消息队列系统工程师，在高性能消息解决方案的设计、实现和优化方面拥有丰富的经验，参与部署过 RocketMQ、Kafka、MQTT 等多个业界领先的消息队列平台。
演讲议题：使用 Apache RocketMQ 赋能无服务器消息架构
分享时间：7 月 26 日 15:0015:30
议题介绍：我们最新的研究成果已被 ACM FSE 2025 行业专题收录，Apache RocketMQ 为无服务器消息系统奠定了坚实的基础，解决了传统中间件在可扩展性、成本和元数据方面的挑战。通过解耦存储和计算，Apache RocketMQ 实现了独立的资源扩展，这对于不可预测的云工作负载至关重要。其弹性写入分区消除了单队列吞吐量限制，而轻量级消息队列则以最小的冷启动延迟支持数百万个队列。
我们通过基于 RocketMQ 的 RabbitMQ 实现证明了这一点，该实现在克服 RabbitMQ 扩展限制的同时，保留了完整的协议兼容性。借助 RocketMQ 的架构，我们实现了无限的水平扩展能力，并将元数据管理效率提高了 1000% 以上。该无服务器解决方案已在阿里云上商业化运营。我们的经验表明，RocketMQ 能够将传统消息系统转型为云原生服务，为面向未来的无服务器架构提供了蓝图。
演讲嘉宾：
SJuntao Ji｜Senior Development Engineer (Alibaba Cloud Computing)
阿里云计算高级中间件研发工程师，负责 RocketMQ 和 RabbitMQ 的功能开发。Apache RocketMQ 开源社区贡献者。在 CCFA 会议或期刊（ASE 23'、FM 24'、FSE 25' 等）发表多篇顶级论文。
演讲议题：基于 Commitlog 和 RocksDB 的 RocketMQ 存储引擎
分享时间：7 月 26 日 15:4516:15
议题介绍：基于 Commitlog 和 RocksDB 的 RocketMQ 存储引擎 延迟消息、事务消息、POP 和索引是 RocketMQ 的核心功能。这些功能涉及内存中的多种状态转换，并且基于文件系统实现。现有实现面临以下问题：
1、基于队列的实现会导致更多的合并操作（例如，POP 消费结果合并、事务消息与 OP 消息合并），从而导致工作流复杂、效率低下且可扩展性差。
2、TimerWheel、TimerLog、Revive 和 Index 文件需要额外的存储空间。
3、内存中过多的中间状态会导致性能问题，例如在 POP 消费过程中，CK、ACK 和 CKMock 等临时对象会对堆内存造成巨大的 GC 压力。
4、大量的磁盘文件和中间状态使分层存储和弹性伸缩变得复杂。
RocksDB 是 Facebook 开发的一款高性能嵌入式键值存储引擎，广泛应用于数据库、日志系统和分布式存储。RocksDB 与 Commitlog 和 RocksDB 统一存储引擎的关键在于将消息数据分离成两部分，在文件系统上 Commitlog 的同时迁移 RocksDB 中的所有索引模型。这种方法具有显著的优势：
1、利用 RocksDB 的快速查找功能减少数据处理中的协调/同步，从而简化复杂性。例如，RocksDB 的键值存储 CRUD 操作可以取代 POP 消费中原有的双队列合并过程。
2、重构存储模型，减少存储数据量，提高存储效率。例如，RocksDB 的索引功能可以完全替代现有的索引功能，无需再保存任何索引文件。
3、使用 RocksDB 作为统一的数据迁移接口，简化了分层存储和弹性伸缩的流程，这比目前的实现方式要早得多。
这种存储架构显著优化了这些核心特性。重构不仅简化了代码库、降低了维护成本，还为 RocketMQ 提供了强大而灵活的解决方案，以应对不断增长的业务需求和复杂的存储环境。
演讲嘉宾：
Zhou Li｜aliyun
阿里云消息专家，负责阿里巴巴核心消息中间件。
演讲议题：RocketMQ 5.0 中的虚拟队列：增强对 Remoting 协议客户端的向后兼容性
分享时间：7 月 26 日 16:1516:45
议题介绍：Apache RocketMQ 是一个以低延迟、高性能和高可靠性著称的分布式消息与流处理平台。最新发布的 5.0 版本带来了两项重大进步：
1、实现了存储与计算的解耦，进一步提升了系统的可扩展性和云原生适配能力。
2、引入了 POP 消费模式，将负载均衡逻辑从客户端迁移到了 Broker 端。 为适应这些新特性，社区推出了全新的基于 gRPC 协议的客户端。然而，现有通过 Remoting 协议客户端接入 RocketMQ 的用户，若不更新代码和替换客户端 SDK，将无法享受到 5.0 的这些创新能力。为增强对 Remoting 协议客户端的向后兼容性，我们在 RocketMQ 5.0 中提出了虚拟队列方案，并已在腾讯云的实际应用中得到了充分验证。
演讲嘉宾：
Shengzhong Liu｜Tencent
自 2019 年从东南大学毕业以来，一直在腾讯云担任软件开发工程师，近年来专注于消息队列技术的相关工作。
演讲议题：小米 RocketMQMQTT 最佳实践：提升质量和成本效率之旅
分享时间：7 月 26 日 16:4517:15
议题介绍：本次演讲将介绍小米 MQTT 系统架构的演变，重点介绍其在稳定性、性能和成本优化方面的进步。关键举措包括管理海量主题、确保消息顺序、灾难恢复机制、分层存储解决方案、字典压缩技术、数据集成、容器化等等。
演讲嘉宾：
Fan Wang｜Xiaomi Message Queue Team Leader, Apache RocketMQ Committer
2018 年加入小米，专注于消息和存储系统，负责小米 MQ、HBase、ElasticSearch 等平台。
点击即可参与报名！
