Integration loosen the coupling between applications Backbone for EDA or CEP Data Replication Streaming 10 33.2 194.2 650 1400 2012 double 11 day 2013 double 11 day 2014 double 11 day 2015 Massive Accumulation  Backoff Strategy  Delivery QoS  Community features – console, docker, streaming etc. © 2 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 Console

RocketMQ 5.0 34 Apache RocketMQ 5.0 35 Apache RocketMQ 5.0 On-Line Analytical Processing Streaming Processing Offline Processing Metrics Logs IoT Data Finance Business Game Implementation 36

umbrella and build community over the world� 2017� 2018� Apache TLP Integrate with ELK, streaming, OLAP systems�� RocketMQ 5.0 Cloud-native, computing storage separating architecture� 典型应⽤用场景

系，一个 Queue 可以由多个消费者消费  无 rebalance ，降低消费延迟概率  集群中某些消费端假死不影响整体消费进度  客户端更加轻量，多语言友好 流批一体  在Streaming场景下，单一消费者消费保证顺 序  在 batch 场景下，无需保证顺序，可以多个 consumer 加快数据读取速度 你集群是正常的，但我消费就是出问题了，怎么办！？ 无损弹性扩缩

examples. Test examples how KEDA works with RocketMQ, Azure queue, service bus, Redis, MySQL, NATS streaming, Kafka, GCP pub/sub - Test RocketMQ examples : Pub/sub, Broadcast, Schedule, Batch, Filter, Logappender

i b a b a - i n c . c o m n 历年双11消息数量变化 n 消息中间件核心链路 n 低延迟存储 n 容量保障 n 熔断机制 n 多副本高可靠 Messaging&Streaming Platform Database changes Log events IoT data Microservice messages … OpenMessaging specification

i b a b a - i n c . c o m n 历年双11消息数量变化 n 消息中间件核心链路 n 低延迟存储 n 容量保障 n 熔断机制 n 多副本高可靠 Messaging&Streaming Platform Database changes Log events IoT data Microservice messages … OpenMessaging specification