rocketmq运维常见故障
社区干货
如何解决使用RocketMQ的消息轨迹信息无法查看问题
# 问题描述RocketMQ 正常生产和消费消息,但是消费轨迹无法查看的问题该如何排查?# 问题分析此类问题原因一般如下:1. 客户端 SDK 使用的版本不对, 需要使用 SDK 版本为 4.8.0, 4.7 和 4.9 的版本均会导致前端页... DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName", aclHook,true,null);```* 消费者开启消息轨迹:```javaAclClientRPCHook aclHook = new AclClientRPCHook(new SessionCredential...
RocketMQ 存储机制浅析
ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文件系统做持久化的情况下,可获得更高效的 I/O 读写。* Broker Store 目录结构``` storePathRootDir=/cache1/rocketmq/broker/data ├── abort // 该文件在 Broker 启动后会自动创建,正常关闭 Broker,该文件会自动消失。若在没有启动 Broker 的情况下,发现这个文件是存...
使用golang调用RocketMQ SDK
# 前言本文档介绍使用go语言调用火山引擎RocketMQ SDK。# 关于实验- 预计部署时间:30分钟- 级别:初级- 相关产品:中间件-RocketMQ- 受众: 通用# 实验说明## 第一步、创建RocketMQ实例在控制台创建RocketMQ... //此处填写控制台RocketMQ实例概览中的TCP内网接入点,目前不支持公网接入,示例http://MQ_INST_50392uo8m9em_xxxxx.rocketmq.ivolces.com:9876 producer.WithRetry(2), producer.WithCredentials(primitive.Cre...
干货|字节跳动流式数据集成基于Flink Checkpoint两阶段提交的实践和优化(1)
> > 字节跳动开发套件数据集成团队(DTS ,Data Transmission Service)在字节跳动内基于 Flink 实现了流批一体的数据集成服务。其中一个典型场景是 Kafka/ByteMQ/RocketMQ -> HDFS/Hive 。Kafka/ByteMQ/RocketMQ ->... 第一篇主要介绍Flink Checkpoint 以及 MQ dump 写入流程。HDFS 集群某个元数据节点由于硬件故障宕机。在该元数据节点终止半小时后,HDFS 手动运维操作将 HDFS 切主到 backup 节点后,HDFS 恢复服务。故障恢复后...
特惠活动
rocketmq运维常见故障-优选内容
rocketmq运维常见故障-相关内容
0014-00000002
问题描述 RocketMQ 实例不具备内部或者公共服务区的访问端点。 问题原因 在创建的 RocketMQ 类型事件通知规则中,所提供的 RocketMQ 实例不具备内部或者公共服务区的访问端点。 问题示例 暂无 解决方案 检查对应 RocketMQ 实例是否勾选内部或者公共服务区访问选项。
0014-00000001
问题描述 AccessKey 不具备发布消息的权限。 问题原因 在创建的 RocketMQ 类型事件通知规则中,所提供的 AccessKey 不具备发布消息的权限。 问题示例 暂无。 解决方案 检查提供的 AccessKey 是否具备对应主题的发布权限。
迁移概述
本指南主要为用户提供 RocketMQ 的迁移方案建议与操作指导。 背景信息火山引擎基于Apache RocketMQ 构建了稳定、安全的消息队列 RocketMQ版。与和开源 RocketMQ 相比,消息队列 RocketMQ版支持 VPC 访问,免部署免运维,具备更高的稳定性和安全性,支持消息查询、全链路消息轨迹查询以及消息回溯等功能,帮助您快速发现和处理系统问题,提高运维效率。RocketMQ 业务迁移是指将自建或其他云厂商的 RocketMQ 迁移到火山引擎消息队列 Rock...
0014-00000009
问题描述 AccessKey 不存在。 问题原因 在创建的 RocketMQ 类型事件通知规则中,所提供的 AccessKey 不存在或者与账号不匹配。 问题示例 暂无。 解决方案 检查提供的 AccessKey 是否正确。
0014-00000004
问题描述 AccessKey 不存在。 问题原因 在创建的 RocketMQ 类型事件通知规则中,所提供的 AccessKey 不存在。 问题示例 暂无。 解决方案 检查提供的 AccessKey 是否正确。
0014-00000006
问题描述 RocketMQ 主题不存在。 问题原因 在创建的 RocketMQ 类型事件通知规则中,所提供的 RocketMQ 主题不存在。 问题示例 暂无。 解决方案 检查提供的主题是否存在,如果不存在,请创建对应主题再重试。
什么是消息队列 RocketMQ版
RocketMQ版提供灵活、可扩展性强的消费主题模式设置,支持发布/订阅、集群消费和广播消费模式。 多种消息类型:消息队列 RocketMQ版支持丰富的消息类型,支持顺序消息、事务消息、定时消息、延时消息等多种消息类型,满足各类场景下的数据消费需求。 多种消息免运维机制:消息队列 RocketMQ版支持消息查询和回溯、消息重试与死信管理等多种消息免运维机制,可配置消费延时、消息堆积等情况下的数据监控与告警,帮助用户及时发现问题。...
跨可用区部署 RocketMQ 实例
跨可用区部署可提高实例的可用性,本文档介绍跨可用区部署方式对于实例的影响。 注意事项创建跨可用区部署的 RocketMQ 实例前,应确认以下问题: 部署 RocketMQ 客户端的 ECS 和 RocketMQ 实例所在的可用区应尽量一致,避免故障域不对等的问题。 跨可用区部署的实例可能会出现 2ms~3ms 的网络延迟,确认单请求时延上升对业务是否有影响。 客户端使用同步方式调用接口的情况下,实例的吞吐性能可能会下降,需要考虑预留一定的性能空间、升...
RocketMQ 客户端使用建议
本文档介绍 RocketMQ 客户端的使用建议,推荐在使用消息队列 RocketMQ版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 日志配置RocketMQ 的日志一般是单独配置的,业务日志独立管理。日志默认... RocketMQ 的日志: Plain -Drocketmq.client.logRoot=指定的日志目录-Drocketmq.client.logFileMaxIndex=指定日志文件个数-Drocketmq.client.logFileMaxSize=单个日志文件大小 InstanceName 问题推荐在不同的集群设...
