阿里云文档 2025-10-27

RocketMQ消费者的原理架构

本文介绍云消息队列 RocketMQ 版中消费者(Consumer)的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。

阿里云文档 2025-06-05

Consumer如何否定应答消息并使其重入队列

您可以通过basicReject或basicNack方法否定应答消息,使消息重入队列,从而是其他Consumer可以消费消息。

阿里云文档 2025-06-05

怎样让Consumer不立即消费消息并使消息重入队列

您可以通过basicReject或basicNack方法否定应答消息,使消息重入队列,从而是其他Consumer可以消费消息。

问答 2024-04-15 来自:开发者社区

当灰度consumer下线时,能够让消息回流到正常的consumer中,RocketMQ能实现吗?

当灰度consumer下线时,能够让消息回流到正常的consumer中,RocketMQ能实现吗?

问答 2023-10-30 来自:开发者社区

请问一下MSE微服务引擎修改Consumer Group的时候需要重启RocketMQ吗?

请问一下MSE微服务引擎全链路灰度的RocketMQ, 修改Consumer Group的时候需要重启RocketMQ吗?

问答 2022-04-15 来自:开发者社区

Demo Consumer能从RocketMq读取到数据,但在调用Kyro序列化时出问题

你好,我们在运行demo的producer将数据积压到RocketMq后,在运行Consumer时也能读到消息,在RocketMq的服务器上使用控制台输出时也能输出数据。但是,在调用RaceUtils.readKryoObject()函数时,函数不返回结果,但Consumer还是能继续获取下一条消息。于是我们在RaceUtils.readKryoObject()函数加了两条输入语句如下: ...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。