云消息队列 MQ机制的相关内容

文章 2024-08-15 来自：开发者社区

RocketMQ - 消费者进度保存机制

RocketMQ设计了远程位点管理和本地位点管理两种位点管理方式。集群消费时，位点由客户端提交给Broker保存，具体实现代码在RemoteBrokerOffsetStore.java文件中；广播消费时，位点保存在消费者本地磁盘上，实现代码在LocalFileOffsetStore.java文件中 ...

文章 2024-08-15 来自：开发者社区

RocketMQ - 消费者Rebalance机制

客户端是通过Rebalance服务做到高可靠的。当发生Broker掉线、消费者实例掉线、Topic 扩容等各种突发情况时，消费者组中的消费者实例是怎么重平衡，以支持全部队列的正常消费的呢？ RebalancePullImpl 和 RebalancePushImpl 两个重平衡实现类，分别被 DefaultMQPullConsumer 和DefaultMQPushConsumer 使用。下...

文章 2024-08-15 来自：开发者社区

RocketMQ - 消费者启动机制

RocketMQ客户端中有两个独立的消费者实现类：org.apache.rocketmq.client.consumer.DefaultMQPullConsumer 和 org.apache.rocketmq.client.consumer.DefaultMQPushConsumer DefaultMQPullConsumer 2022年已弃用，使用 DefaultL...

问答 2024-08-14 来自：开发者社区

Flink中通过MQ的连接器消费数据时有确认机制吗？

Flink中通过MQ的连接器消费数据时有确认机制吗？比如我消费成功了，mq那边能确认消费成功。在官方的配置文档中没有看到有类似回调的参数

文章 2024-07-29 来自：开发者社区

消息队列 MQ使用问题之过期删除机制的触发条件是什么

问题一：阿里云RocketMQ服务中消费者group是不是都要自己在页面上创建？阿里云RocketMQ服务中消费者group是不是都要自己在页面上创建？连default这个都没有参考答案：楼主你好，据我所知在阿里云RocketMQ服务中，消费者组是由消费者应用程序在编码中创建的，而不是在控制台页面上创建的，阿里云RocketMQ服务只提供了创建和...

问答 2024-07-10 来自：开发者社区

RocketMQ4.0版本和 5.0 版本是不是都有断开重连机制？

RocketMQ4.0版本和 5.0 版本是不是都有断开重连机制？我说的是阿里云提供的client的包

问答 2024-07-02 来自：开发者社区

RocketMQ ACL 2.0的插件化机制有何优势？

文章 2024-06-10 来自：开发者社区

消息队列 MQ产品使用合集之是否提供机制检测消费的状态

问题一：在Apache RocketMQ中这种情况队列数量应该设置多少比较合理呢？在Apache RocketMQ中这种情况队列数量应该设置多少比较合理呢？参考回答：你这最多一个队列对应一台机器吧，机器数<=队列数即可。关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/57567...

问答 2024-06-10 来自：开发者社区