GSoC 2020 Apache Proposal
Apache RocketMQ Scaler for KEDAKEDA is written in Go (gPRC). KEDA has ScaledObject for the service, Metrics adapter, Scaler, Controller. RocketMQ operator deployment on Kubernetes also support Horizontal scale with Name server cluster0 码力 | 7 页 | 140.48 KB | 1 年前3
万亿级数据洪峰下的消息引擎Apache RocketMQMachine. • Maintain ephemeral broker status. • Notification mechanism when there is a change. Controller provides: • Watch broker status’s change. • Handle state machine transition and push new state0 码力 | 35 页 | 993.29 KB | 1 年前3
万亿级数据洪峰下的消息引擎 Apache RocketMQMachine. • Maintain ephemeral broker status. • Notification mechanism when there is a change. Controller provides: • Watch broker status’s change. • Handle state machine transition and push new state0 码力 | 35 页 | 5.82 MB | 1 年前3
Apache RocketMQ 从入门到实战接口为 /consumer/groupList. query,那接下来,我们首先从源码的角度来分析该接口的实现逻辑。其入口如下: org.apache.rocketmq.console.controller.ConsumerController#list @RequestMapping(value = "/groupList.query") @ResponseBody public Object0 码力 | 165 页 | 12.53 MB | 1 年前3
共 4 条
- 1













