Github: ​https://github.com/hiejulia Related skills : Java, Golang, SQL, NoSQL, Rest, gPRC, Microservices, Test, DevOps, Distributed system, Cloud(AWS, Azure) , Golang, Maven, Docker, Kubernetes GSoC deployment is actively processing messages, or each replica is processing a batch of messages in a distributed manner - ScaledObject ​is used to define how KEDA scale and triggers - Logic to handle long Batch example : send messages in batches, split into lists - Filter example: RocketMQ offer some SQL expression to filter out message - Logappender example: - Open Message example: OMS Producer &

Apache RocketMQ 5.0, embracing the Distributed Messaging Standard OpenMessaging Presented By : ��(Von Gosling) 3 Safe Harbor Statement The following is intended to outline our general product direction Team Leader Open-source Enthusiast, active speaker and writer, have rich experience in distributed system, system performance and web architecture Email: vongosling@apache.org Presentation Agenda

IaaS 基础设施支持，降低成本 轻量级SDK： • 全面支持云原生通信标准 gRPC 协议 • 无状态 Pop 消费模式，多语言友好，易集成 从业务走向数据： • 事件流场景支撑 • 面向 SQL 的轻量级实时计算引擎 可分可合的存储计算分离： • Broker 升级为真正的无状态服务节点，无 binding • Broker和Store节点分离部署、独立扩缩 • 可分可合，适应多种业务场景，降低运维负担

w th sync mode to avoid message loss Supported Supported, property filter expressi ns based on SQL92 Supported High performance and low latency file storage upported timestamp and offset two indicates

Message File Service Aliware MQ Apache RocketMQ Replication DB Connector Third party partner SQL/RPC Filter DC Router Multi- tenancy Exactly Only once 24/7 Support LOG Connector IoT Connector

Message File Service Aliware MQ Apache RocketMQ Replication DB Connector Third party partner SQL/RPC Filter DC Router Multi- tenancy Exactly Only once 24/7 Support LOG Connector IoT Connector

0 1 7 A l i b a b a M i d d l e w a r e G r o u p PROFILE MCS, has rich experience in distributed system design and performance tuning, especially in messaging system, cloud computing, etc.

html  CORBA Notification Service Specification 1.1 http://www.omg.org/spec/NOT/1.1/PDF  Distributed Transaction Processing: The XA Specification http://pubs.opengroup.org/onlinepubs/009680699/toc

消息过滤是指消费端可以根据某些条件对一个 topic 中的消息进行过滤，即只消费一个 主题下满足过滤条件的消息。 RocketMQ 目前主要的过滤机制是基于 tag 的过滤与基于消息属性的过滤，基于消息 属性的过滤支持 SQL92 表达式，对消息进行过滤。 六、小结 本文的主要目的是介绍 RocketMQ 常见的术语，例如 nameserver、broker、主题、 消费组、消费者、队列负载算法、队列重平衡机制、并发消费、顺序消费、消费进度存储、