rocketmq消费连接
社区干货
如何解决使用RocketMQ的消息轨迹信息无法查看问题
# 问题描述RocketMQ 正常生产和消费消息,但是消费轨迹无法查看的问题该如何排查?# 问题分析此类问题原因一般如下:1. 客户端 SDK 使用的版本不对, 需要使用 SDK 版本为 4.8.0, 4.7 和 4.9 的版本均会导致前端页... 消费轨迹功能,enableMsgTrace 需要设置为 true,* 生产者开启消息轨迹:```javaAclClientRPCHook aclHook = new AclClientRPCHook(new SessionCredentials(ACL_ACCESS_KEY,ACL_SECRET_KEY));DefaultMQProducer ...
RocketMQ 存储机制浅析
ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文件系统做持久化的情况下,可获得更高效的 I/O 读写。* Broker Store 目录结构``` storePathRootDir=/cache1/rocketmq/broker/data ├── abort // 该文件在 Broker 启动后会自动创建,正常关闭 Broker,该文件会自动消失。若在没有启动 Broker 的情况下,发现这个文件是存...
打造新一代云原生"消息、事件、流"统一消息引擎的融合处理平台 | 社区征文
RocketMQ基于大规模云计算环境的实践经验(例如,阿里(双十一、双十二)、携程(过年高峰期)),辅助了成千上万的企业完成数字化转型,从而实现了从互联网消息中间件到云原生消息中间件的发展变革。RocketMQ与其他消息中间... 比如RabbitMQ无法水平扩展单队列能力、Kafka扩容需要大量数据拷贝和均衡。这些现有解决方案都不适用于为大规模客户提供弹性服务的公共云环境。, producer.WithCredentials(primitive.Cre...
特惠活动
rocketmq消费连接-优选内容
rocketmq消费连接-相关内容
通过 RocketMQ 消费火山引擎 Proto 格式的订阅数据
数据库传输服务 DTS 的数据订阅服务支持使用 RocketMQ 客户端消费火山引擎 Proto 格式的订阅数据。本文以订阅云数据库 MySQL 版实例为例,介绍如何使用 Go 和 Java 语言消费 Canal 格式的数据。 前提条件已注册火山... import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; import org.apache.rocketmq.client.consumer.listener.*; import org.apache.rocketmq.common.message.MessageExt; import org.apache.rock...
ResetGroupOffset
调用 ResetGroupOffset 接口重置指定 Group ID 的消费位点。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 使用说明消息队列 RocketMQ版支持重置 Group 订阅的某一 Topic 或... 请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 必选 MQ_INST_******** 实例 ID。 Group String 必选 GID-123123 需要重置消费位点的 Group ID。 Mode String 必选 Latest ...
创建 RocketMQ 触发器
函数服务支持对接火山引擎的 消息队列 RocketMQ 版。 通过创建 RocketMQ 触发器,函数服务将作为消费者消费 RocketMQ 中的消息,并将消息传递给用户函数,触发函数代码逻辑。您无需关心函数服务消费消息的细节,只需编... 详细操作可参见 RocketMQ 快速入门。 使用限制每个函数最多支持创建 20 个触发器。 RocketMQ 实例和函数必须处于同一 VPC 下。 若需要修改函数的 VPC 或子网,必须先停用或删除所有的 MQ 触发器。 RocketMQ 触发器...
产品规格
消息队列 RocketMQ版兼容 Apache RocketMQ,提供多种计算规格和存储容量供您选择。 计算规格计算规格决定了 RocketMQ 实例的业务处理性能。消息队列 RocketMQ版提供以下计算规格供选择,每个规格的推荐 TPS 峰值、最大消费组数、最大 Topic 数、最大连接数和最大队列数不同。 规格名称 推荐 TPS 峰值 最大消费组数 最大 Topic 数 最大连接数 最大队列数 rocketmq.n1.x2.micro 2000 400 400 2000 400 rocketmq.n1.x2.ti...
查看 Topic 消费信息
创建 Topic 之后,如果这个 Topic 中的数据被一些消费者消费,消息队列 RocketMQ版会记录并在控制台展示消费的相关信息,例如队列信息和消费组信息。 操作入口登录消息队列 RocketMQ版控制台。 在顶部菜单栏中选择地域。 在实例列表中找到指定 RocketMQ 实例,并单击实例名称。 在Topic管理页面单击指定 Topic 名称。除 Topic 基本信息外,页面中以页签形式展示该 Topic 的队列信息、订阅此 Topic 的消费组信息和 Topic 的密钥权限。 ...
CreateGroup
调用 CreateGroup 创建一个新的消费组(Group)。 注意事项请求频率:该接口请求频率限制为 20 次/秒;单用户请求频率限制为 4 次/秒。 使用说明在消息队列 RocketMQ版中,您需要创建 Group,并通过 Group ID 标识不同类别的生产者或消费者。 每个实例的 Topic 数量配额与实例规格有关,例如各个规格实例可创建的 Topic 数量请参考产品规格。 消费者必须配置 Group ID,生产者可以忽略 Group ID 配置。 目前支持的客户端协议为 TCP。 请...
RocketMQ 业务迁移
如果有多个 RocketMQ 实例需要迁移到同一个消息队列 RocketMQ版实例中,请依次进行迁移。 如果使用延时消息,建议将旧实例消费端保存 3 天或更长时间。 业务迁移只迁移消息生产和消费链路,并不会迁移 RocketMQ 旧集... 迁移后您的服务需要和 RocketMQ 实例处于相同的区域(Region)和 VPC 内,才能正常访问实例。详细操作步骤请参考 创建私有网络 。 购买 ECS 云服务器实例。在连接 RocketMQ 实例之前,您需要先购买 ECS 云服务器,安...
RocketMQ 生产者使用建议
本文档介绍 RocketMQ 生产者的使用建议,推荐在使用消息队列 RocketMQ版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 消息 Tag建议组合使用 Topic 和 tags,以减少 Topic 的使用。 Tag 可以由应用自行设置。 仅当生产者在发送消息时设置了 Tag,消费者在订阅消息时才可以利用 Tag 进行消息过滤,例如 message.setTags("TagA")。消费者在 Broker 侧根据 Tag 的 hashcode 进行初步过滤,在消费端根据字符串过滤...
查看 Group 消费状态
成功创建 Group 并启动消费之后,消息队列 RocketMQ版会记录并在控制台展示消费的相关信息,例如消费速度等基础消费信息、客户端IP等客户端信息、订阅的 Topic 等订阅信息。 操作入口登录消息队列 RocketMQ版控制台。 在顶部菜单栏中选择地域。 在实例列表中找到指定 RocketMQ 实例,并单击实例名称。 在Group管理页面单击指定 Group ID。 分别查看消费信息、客户端信息和订阅信息。 查看消费信息消费信息区域展示消费的整体状态、...
