爆款云主机2核2G28.8元/年起!
查看详情

活动

天翼云最新优惠活动,涵盖免费试用,产品折扣等,助您降本增效!
热门活动
  • 12.12年度钜惠 NEW 爆款云主机2核2G仅需28.8元/年,X实例35.1元/半年起! 8代机+XSSD新客专享2.5折!
  • 免费体验DeepSeek,上天翼云息壤 NEW 新老用户均可免费体验2500万Tokens,限时两周
  • 云上钜惠 HOT 爆款云主机全场特惠,更有万元锦鲤券等你来领!
  • 算力套餐 HOT 让算力触手可及
  • 天翼云AI产品特惠 NEW 人脸识别+文字识别焕新,新用户免费试用
  • 中小企业服务商合作专区 国家云助力中小企业腾飞,高额上云补贴重磅上线
  • 出海产品促销专区 NEW 爆款云主机低至2折,高性价比,不限新老速来抢购!
  • 天翼云电脑专场 HOT 移动办公新选择,爆款4核8G畅享1年3.5折起,快来抢购!
  • 天翼云奖励推广计划 加入成为云推官,推荐新用户注册下单得现金奖励
免费活动
  • 免费试用中心 HOT 多款云产品免费试用,快来开启云上之旅
  • 天翼云用户体验官 NEW 您的洞察,重塑科技边界

息壤智算

领先开放的智算服务平台,提供算力、平台、数据、模型、应用“五位一体”智算服务体系,构建全流程的AI基础设施能力
智算云(DeepSeek专区)
AI Store
  • 算力市场
  • 模型市场
  • 应用市场
  • MCP市场
算力互联调度平台
  • 裸金属
  • 定制裸金属
训推服务
  • 模型开发
  • 训练任务
  • 服务部署
模型推理服务
  • 模型广场
  • 体验中心
  • 服务接入
应用托管
  • 应用实例
科研助手
  • 科研智能体
  • 科研服务
  • 开发机
  • 并行计算
大模型
  • DeepSeek-V3.1
  • DeepSeek-R1-0528
  • DeepSeek-V3-0324
  • Qwen3-235B-A22B
  • Qwen3-32B
智算一体机
  • 智算一体机
模型适配专家服务
  • 模型适配专家服务
算力服务商
  • 入驻算力服务商

应用商城

天翼云精选行业优秀合作伙伴及千余款商品,提供一站式云上应用服务
进入甄选商城进入云市场进入AI Store创新解决方案智云上海应用生态专区
AI应用
  • 泛微合同管理解决方案
  • 泛微数智大脑Xiaoe.AI解决方案
  • MaxKB知识库解决方案
  • 天翼AI文创
AI服务
  • 昆仑AI训推服务解决方案
  • 国信模型服务解决方案
企业应用
  • 翼电子签约解决方案
  • 翼协同解决方案
  • 翼电签-契约锁解决方案
  • 翼视频云归档解决方案
教育应用
  • 翼电子教室
  • 潜在AI教育解决方案
建站工具
  • SSL证书
  • 翼定制建站解决方案
  • 翼多端小程序解决方案
办公协同
  • 天翼云企业云盘
  • 安全邮箱
灾备迁移
  • 云管家2.0
资源管理
  • 全栈混合云敏捷版(软件)
  • 全栈混合云敏捷版(一体机)

定价

协助您快速了解云产品计费模式、价格详情,轻松预估上云成本
价格计算器
  • 动态测算产品价格
定价策略
  • 快速了解计费模式

合作伙伴

天翼云携手合作伙伴,共创云上生态,合作共赢
天翼云生态合作中心
  • 天翼云生态合作中心
天翼云渠道合作伙伴
  • 天翼云代理渠道合作伙伴
天翼云服务合作伙伴
  • 天翼云集成商交付能力认证
天翼云应用合作伙伴
  • 天翼云云市场合作伙伴
  • 天翼云甄选商城合作伙伴
天翼云技术合作伙伴
  • 天翼云OpenAPI中心
天翼云培训认证
  • 天翼云学堂
  • 天翼云市场商学院
天翼云合作计划
  • 云汇计划
天翼信创云专区
  • 信创云专区
  • 适配互认证

开发者

开发者相关功能入口汇聚
技术社区
  • 专栏文章
  • 互动问答
  • 技术视频
资源与工具
  • OpenAPI中心
培训与认证
  • 天翼云学堂
  • 天翼云认证
魔乐社区
  • 魔乐社区

支持与服务

为您提供全方位支持与服务,全流程技术保障,助您轻松上云,安全无忧
文档与工具
  • 文档中心
  • 新手上云
  • 自助服务
  • OpenAPI中心
定价
  • 价格计算器
  • 定价策略
基础服务
  • 售前咨询
  • 在线支持
  • 在线支持
  • 工单服务
  • 服务保障
  • 会员中心
增值服务
  • 红心服务
  • 首保服务
  • 客户支持计划
  • 专家技术服务
  • 备案管家
我要反馈
  • 建议与反馈
  • 用户体验官
信息公告
  • 客户公告

了解天翼云

天翼云秉承央企使命,致力于成为数字经济主力军,投身科技强国伟大事业,为用户提供安全、普惠云服务
品牌介绍
  • 关于天翼云
  • 智算云
  • 天翼云4.0
  • 新闻资讯
  • 天翼云APP
基础设施
  • 全球基础设施
  • 信任中心
最佳实践
  • 精选案例
  • 超级探访
  • 云杂志
  • 分析师和白皮书
  • 天翼云·创新直播间
市场活动
  • 2025智能云生态大会
  • 2024智算云生态大会
  • 2023云生态大会
  • 2022云生态大会
  • 天翼云中国行
天翼云
  • 活动
  • 息壤智算
  • 产品
  • 解决方案
  • 应用商城
  • 定价
  • 合作伙伴
  • 开发者
  • 支持与服务
  • 了解天翼云
      • 文档
      • 控制中心
      • 备案
      • 管理中心
      天翼云分布式消息服务_相关内容
      • 查询消息
        本章节介绍了如何查询分布式消息服务RocketMQ实例的消息。 操作场景 本章节指导您通过查询消息功能查看具体的消息内容,以及确定消息是否生产/消费成功。 分布式消息服务RocketMQ提供三种消息查询的方法:按Topic查询、按Message ID查询和按Message Key查询。 按Topic查询:查询某时间段内指定Topic下所有的消息。此方法属于范围查询,查询到的消息可能比较多。 按Message ID查询:查询指定Message ID的消息。
        来自:
        帮助文档
        分布式消息服务RocketMQ
        用户指南
        消息查询
        查询消息
      • 消息重试
        消息重试 消费者出现异常,分布式消息服务RocketMQ会根据消费重试策略重新投递该消息进行故障恢复。本文主要介绍分布式消息服务RocketMQ中消息重试与使用方法。功能介绍 当消息第一次被消费者消费后,没有得到正常的回应,或者用户要求服务端重投,分布式消息服务RocketMQ会通过消费重试机制自动重新投递该消息,直到该消息被成功消费,当重试达到一定次数后,消息仍未被成功消费,则会停止重试,将消息投递到死信队列中。
        来自:
        帮助文档
        分布式消息服务RocketMQ
        用户指南
        管理消息
        消息重试
      • 消息类
        本章节介绍了有关分布式消息服务RocketMQ实例消息类的常见问题及解答。 是否支持消费验证? 分布式消息服务RocketMQ当前不支持消费验证功能。 RocketMQ的消息保留时间是多少?可以修改吗? RocketMQ的消息保留时间是48小时,且不支持修改。 RocketMQ支持的最大消息大小是多少?可以修改吗? RocketMQ支持的最大消息大小是4M,且不支持修改。 RocketMQ副本存储形式是怎样的?可以修改吗? RocketMQ消息是一主两从3个副本的存储形式,且不支持修改。
        来自:
        帮助文档
        分布式消息服务RocketMQ
        常见问题
        消息类
      • 分布式缓存服务Redis
        云日志服务支持采集分布式缓存服务Redis日志,您可在Redis实例控制台中进行开启日志收集,由云日志服务提供存储与采集能力。采集后,您可以在云日志服务控制台对redis日志进行查询、分析或告警配置。前提条件已订购分布式缓存服务Redis实例。已开通云日志服务。配置步骤登录分布式缓存服务Redis控制台。在实例管理列表中,点击目标实例名称,进入实例详情页面。点击左侧菜单栏“日志管理”-“审计日志”根据页面提示,点击“马上开启”按钮。
        来自:
        帮助文档
        云日志服务
        用户指南
        日志接入
        云服务日志接入
        分布式缓存服务Redis
      • 服务内联委托管理
        建立消息中间件事件源与事件目标时,需要委托事件总线EventBridge具有对分布式消息服务Kafka、分布式消息服务RocketMQ、分布式消息服务MQTT与分布式消息服务RabbitMQ的管理员权限。建立网络端点时,需要委托事件总线EventBridge具有专有网络VPC、VPCE的管理员权限。
        来自:
        帮助文档
        事件总线
        产品简介
        服务内联委托管理
      • 收发事务消息
        import time from rocketmq.client import PushConsumer, ConsumeStatus en...分布式消息服务RocketMQ控制台Namesrv接入点 access_key = "${ACCESS_KEY}" # 填写AccessKey 在分布式消息服务RocketMQ控制台用户管理菜单中创建的用户ID access_secret = "${SECRET_KEY}" # 填写SecretKey 在分布式消息服务
        来自:
        帮助文档
        分布式消息服务RocketMQ
        开发指南
        Python
        收发事务消息
      • 收发定时/延时消息
        分布式消息服务RocketMQ版支持任意时间的定时消息,最大推迟时间可达到40天。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后,消息不会立即被消费,而是延迟到设定的时间点后才会发送给消费者进行消费。 收发消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 准备环境 在命令行输入python,检查是否已安装Python。得到如下回显,说明Python已安装。
        来自:
        帮助文档
        分布式消息服务RocketMQ
        开发指南
        Python
        收发定时/延时消息
      • 云审计服务支持的RocketMQ操作列表
        本页面主要介绍分布式消息服务RocketMQ对接的云审计服务使用和查看方法。 操作场景本服务现已对接天翼云云审计服务,云审计服务提供对各种云资源操作的记录和查询功能,用于支撑合规审计、安全分析、操作追踪和问题定位等场景,同时提供事件跟踪功能,将操作日志转储至对象存储实现永久保存。云审计可提供的功能服务具体如下:● 记录审计日志:支持用户通过管理控制台或API接口发起的操作,以及各服务内部自触发的操作。
        来自:
        帮助文档
        分布式消息服务RocketMQ
        用户指南
        云审计服务支持的关键操作
        云审计服务支持的RocketMQ操作列表
      • 收发顺序消息
        from rocketmq.client import Producer, Message endpoint = "${ENDPOINT}"...分布式消息服务RocketMQ控制台Namesrv接入点 access_key = "${ACCESS_KEY}" # 填写AccessKey 在分布式消息服务RocketMQ控制台用户管理菜单中创建的用户ID access_secret = "${SECRET_KEY}" # 填写SecretKey 在分布式消息服务RocketMQ控制台用户管理菜单中创建的用户密钥
        来自:
        帮助文档
        分布式消息服务RocketMQ
        开发指南
        Python
        收发顺序消息
      • 基于事件流实现RabbitMQ消息路由
        本文介绍如何应用事件总线EventBridge的事件流功能实现分布式消息服务RabbitMQ的消息路由。前提条件开通事件总线EventBridge并授权。开通分布式消息服务RabbitMQ并开通实例。背景信息事件流作为更轻量、实时端到端的流式事件通道,提供轻量级的流式数据的过滤和转换的能力,在不同的数据仓库之间、数据处理程序之间、数据分析和处理系统之间进行数据同步。源端分布式消息服务RabbitMQ生产的消息可以通过事件流这个通道被路由到目标端的分布式消息服务RabbitMQ。
        来自:
        帮助文档
        事件总线
        最佳实践
        基于事件流实现消息路由
        基于事件流实现RabbitMQ消息路由
      • 收发普通消息
        from rocketmq.client import Producer, Message endpoint = "${ENDPOINT}"...分布式消息服务RocketMQ控制台Namesrv接入点 access_key = "${ACCESS_KEY}" # 填写AccessKey 在分布式消息服务RocketMQ控制台用户管理菜单中创建的用户ID access_secret = "${SECRET_KEY}" # 填写SecretKey 在分布式消息服务RocketMQ控制台用户管理菜单中创建的用户密钥
        来自:
        帮助文档
        分布式消息服务RocketMQ
        开发指南
        Python
        收发普通消息
      • 产品优势
        全托管服务 分布式消息服务RocketMQ提供自动部署与完备的运维系统和售后服务,提供包括监控告警在内的多种运维手段,业务无需过多关注分布式消息服务RocketMQ的部署与运维工作,可以专注于自身业务的开发。 低延迟 基于天翼云网络部署,在内网访问可达微秒级时延。 弹性高可靠 基于Raft协议实现集群内部节点的管理,及时发现故障节点并进行流量迁移,保证业务的连续性可靠。 动态扩展 提供业务集群动态扩容的能力,根据业务需要动态扩容集群规模。
        来自:
        帮助文档
        分布式消息服务RocketMQ
        产品简介
        产品优势
      • 基于事件流实现RocketMQ消息路由
        本文介绍如何应用事件总线EventBridge的事件流功能实现分布式消息服务RocketMQ的消息路由。前提条件开通事件总线EventBridge并授权。开通分布式消息服务RocketMQ并创建最少两个主题。背景信息事件流作为更轻量、实时端到端的流式事件通道,提供轻量级的流式数据的过滤和转换的能力,在不同的数据仓库之间、数据处理程序之间、数据分析和处理系统之间进行数据同步。源端分布式消息服务RocketMQ生产的消息可以通过事件流这个通道被路由到目标端的分布式消息服务RocketMQ。
        来自:
        帮助文档
        事件总线
        最佳实践
        基于事件流实现消息路由
        基于事件流实现RocketMQ消息路由
      • 与其他服务关系
        本文为您介绍分布式消息服务MQTT与其他服务关系。 虚拟私有云(CT-VPC ,Virtual Private Cloud) 虚拟私有云为分布式消息服务MQTT提供一个逻辑隔离的区域,构建一个安全可靠、可配置和管理的虚拟网络环境。更多信息请参见虚拟私有云。 弹性云主机(CT-ECS,Elastic Cloud Server) 弹性云主机由 CPU、内存、镜像、云硬盘组成,同时结合VPC、安全组、数据多副本保存等能力,打造一个既高效又可靠安全的计算环境,确保分布式消息服务MQTT持久稳定运行。
        来自:
        帮助文档
        分布式消息服务MQTT
        产品介绍
        与其他服务关系
      • 基于事件流实现Kafka消息路由
        本文介绍如何应用事件总线EventBridge的事件流功能实现分布式消息服务Kafka的消息路由。前提条件开通事件总线EventBridge并授权。开通分布式消息服务Kafka并创建最少两个主题。背景信息事件流作为更轻量、实时端到端的流式事件通道,提供轻量级的流式数据的过滤和转换的能力,在不同的数据仓库之间、数据处理程序之间、数据分析和处理系统之间进行数据同步。源端分布式消息服务Kafka生产的消息可以通过事件流这个通道被路由到目标端的分布式消息服务Kafka。
        来自:
        帮助文档
        事件总线
        最佳实践
        基于事件流实现消息路由
        基于事件流实现Kafka消息路由
      • 收发普通消息
        准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.7。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。
        来自:
        帮助文档
        分布式消息服务RocketMQ
        开发指南
        Java
        收发普通消息
      • 收发顺序消息
        全局顺序消息和分区顺序消息的区别仅为队列数量不同,代码没有区别。 收发消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.7。 通过以下任意一种方式引入依赖: 使用Maven方式引入依赖。
        来自:
        帮助文档
        分布式消息服务RocketMQ
        开发指南
        Java
        收发顺序消息
      • RabbitMQ自定义策略
        本章节主要介绍分布式消息服务RabbitMQ的自定义策略。 如果系统预置的分布式消息服务RabbitMQ权限,不满足您的授权要求,可以创建自定义策略。 目前天翼云支持以下两种方式创建自定义策略: 可视化视图创建自定义策略:无需了解策略语法,按可视化视图导航栏选择云服务、操作、资源、条件等策略内容,可自动生成策略。 JSON视图创建自定义策略:可以在选择策略模板后,根据具体需求编辑策略内容;也可以直接在编辑框内编写JSON格式的策略内容。
        来自:
        帮助文档
        分布式消息服务RabbitMQ
        用户指南
        权限管理
        RabbitMQ自定义策略
      • 设备轨迹
        本文为您介绍分布式消息服务MQTT的操作指南-设备轨迹。 分布式消息服务MQTT支持按clientId按天维度查询设备轨迹,以帮助排查设备在线问题和定位问题的原因。通过设备轨迹查询,您可以获取设备的连接历史和动作说明,以便更好地了解设备的行为和状态。 操作步骤 1、 天翼云官网点击控制中心,选择产品分布式消息服务MQTT。 2、 登录分布式消息服务MQTT控制台,点击右上角地域选择对应资源池。 3、 进入实例列表,点击【管理】按钮进入管理菜单。
        来自:
        帮助文档
        分布式消息服务MQTT
        用户指南
        设备轨迹
      • 云审计服务支持的MQTT操作列表
        本页面主要介绍分布式消息服务MQTT对接的云审计服务使用和查看方法。 操作场景本服务现已对接天翼云云审计服务,云审计服务提供对各种云资源操作的记录和查询功能,用于支撑合规审计、安全分析、操作追踪和问题定位等场景,同时提供事件跟踪功能,将操作日志转储至对象存储实现永久保存。云审计可提供的功能服务具体如下:● 记录审计日志:支持用户通过管理控制台或API接口发起的操作,以及各服务内部自触发的操作。
        来自:
        帮助文档
        分布式消息服务MQTT
        用户指南
        云审计服务支持的关键操作
        云审计服务支持的MQTT操作列表
      • 认证授权
        本文为您介绍分布式消息服务MQTT的操作指南-认证授权。 创建用户名和密码 终端设备连接MQTT队列需要先创建用户密码。 1、 天翼云官网点击控制中心,选择产品分布式消息服务MQTT。 2、 登录分布式消息服务MQTT控制台,点击右上角地域选择对应资源池。 3、 进入实例列表,点击【管理】按钮进入管理菜单。 4、 进入认证授权菜单,点击【新增】按钮,在弹出框输入认证用户名、用户密码、确认密码等信息。 主题授权 对用户名进行主题授权,客户端方可正常收发。
        来自:
        帮助文档
        分布式消息服务MQTT
        用户指南
        认证授权
      • 生产消息
        介绍分布式消息服务Kafka生产拨测功能操作内容。 场景描述 通过生产消息,确保Kafka集群能够稳定接收并传递生产者发送的消息,同时消费者能够成功订阅并处理这些消息,以此确认集群的基本功能和网络连接均处于正常状态。 操作步骤 (1)登录管理控制台。 (2)进入Kafka管理控制台。 (3)在实例列表页在操作列,目标实例行点击“管理”。 (4)点击“Topic管理”后进入主题管理页面。 (5)选择需要生产消息的Topic,点击其右侧“更多”,在下拉框中点击“生产消息”按钮。
        来自:
        帮助文档
        分布式消息服务Kafka
        用户指南
        Topic管理
        生产消息
      • 收发事务消息
        收发事务消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.7。
        来自:
        帮助文档
        分布式消息服务RocketMQ
        开发指南
        Java
        收发事务消息
      • 从服务端应用向消息队列MQTT版发送单条消息
        本文为您介绍分布式消息服务MQTT的API-消息发送。
        来自:
        帮助文档
        分布式消息服务MQTT
        API参考
        API
        消息发送
        从服务端应用向消息队列MQTT版发送单条消息
      • 天翼云分布式缓存服务协议
        产品服务协议请查看:产品服务协议产品服务等级协议请查看:产品服务等级协议
        来自:
        帮助文档
        分布式缓存服务Redis版
        相关协议
        天翼云分布式缓存服务协议
      • 收发定时/延时消息
        分布式消息服务RocketMQ版支持任意时间的定时消息,最大推迟时间可达到40天。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后,消息不会立即被消费,而是延迟到设定的时间点后才会发送给消费者进行消费。 发送定时消息前,请参考收集连接信息收集RocketMQ所需的连接信息。 适用场景 定时消息适用于以下场景: 消息对应的业务逻辑有时间窗口要求,如电商交易中超时未支付关闭订单的场景。
        来自:
        帮助文档
        分布式消息服务RocketMQ
        开发指南
        Java
        收发定时/延时消息
      • 使用IAM授权的云服务
        CDN与边缘云服务类别区域控制台OpenAPI系统策略支持IAM支持企业项目支持IAM支持企业项目边缘安全加速平台全局是是是是有容器与中间件云服务名称区域 控制台OpenAPI系统策略支持IAM支持企业项目支持IAM支持企业项目分布式消息服务Kafka全局是是是是有分布式消息服务RabbitMQ全局是是是是有分布式消息服务RocketMQ全局是是是是有微服务云应用平台全局是是是是有云容器引擎全局是是是是有弹性容器实例全局是是是是有函数计算全局是是是是有云日志服务LTS全局是是是是有容器镜像服务全局是是是是有分布式消息服务
        来自:
        帮助文档
        统一身份认证(一类节点)
        产品概述
        使用IAM授权的云服务
      • 创建数据订阅任务
        前提条件 注册天翼云账号,并完成实名认证。具体操作,请参见天翼云账号注册流程。 注意数据订阅功能数据类型支持指标数据、事件数据及告警数据,订阅方式支持分布式消息服务及API方式。指标数据订阅支持分布式消息服务(kafka)及remotewrite-api方式。事件数据订阅/告警数据订阅支持分布式消息服务(kafka)及api-push方式。分布式消息服务(kafka)需要客户提前部署资源,在云监控平台创建订阅任务时填写相关客户端配置信息。 操作步骤 登录控制中心。
        来自:
        帮助文档
        云监控服务
        用户指南
        数据订阅
        创建数据订阅任务
      • 认证与访问控制
        介绍分布式消息服务Kafka认证与访问控制方式 分布式消息服务Kafka支持CTIAM身份认证和多种访问控制,多维度保障您数据的安全。 身份认证 CTIAM 统一身份认证(Identity and Access Management, 简称:CTIAM)是提供用户进行权限管理的基础服务,可以帮助您安全的控制天翼云服务和资源的访问及操作权限,包括:用户身份认证、权限分配、访问控制等功能。具体介绍请参考统一身份认证-产品介绍。
        来自:
        帮助文档
        分布式消息服务Kafka
        产品简介
        安全
        认证与访问控制
      • Rabbitmq消息确认机制
        介绍 分布式消息服务RabbitMQ消息确认机制。 消息确认 RabbitMQ消息确认机制分为发送消息确认和消息接收确认。 发送消息确认 生产者确认,即为生产者发送消息后,等待服务端确认。
        来自:
        帮助文档
        分布式消息服务RabbitMQ
        用户指南
        高级特性
        Rabbitmq消息确认机制
      • 云审计服务支持的RabbitMQ操作列表
        本页面主要介绍分布式消息服务RabbitMQ对接的云审计服务使用和查看方法。 操作场景本服务现已对接天翼云云审计服务,云审计服务提供对各种云资源操作的记录和查询功能,用于支撑合规审计、安全分析、操作追踪和问题定位等场景,同时提供事件跟踪功能,将操作日志转储至对象存储实现永久保存。云审计可提供的功能服务具体如下:● 记录审计日志:支持用户通过管理控制台或API接口发起的操作,以及各服务内部自触发的操作。
        来自:
        帮助文档
        分布式消息服务RabbitMQ
        用户指南
        云审计服务支持的关键操作
        云审计服务支持的RabbitMQ操作列表
      • 消息堆积
        介绍分布式消息服务Kafka消息堆积功能操作内容。 场景描述 Kafka消息堆积的场景包括以下几个: 消费者处理延迟:当消费者的处理能力不足或出现故障时,无法及时消费Kafka中的消息,导致消息堆积。这可能是由于消费者的处理逻辑复杂、处理速度慢,或者消费者的资源不足等原因引起的。 网络故障:当Kafka集群与消费者之间的网络出现故障或不稳定时,可能导致消息传输延迟或中断。这会导致消息在Kafka中堆积,等待网络恢复后才能被消费。
        来自:
        帮助文档
        分布式消息服务Kafka
        用户指南
        消费组管理
        消息堆积
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • ...
      • 313
      跳转至
      推荐热词
      天翼云运维管理审计系统天翼云云服务平台云服务备份云日志服务应用运维管理云手机云电脑天翼云云hbase数据库电信云大数据saas服务电信云大数据paas服务轻量型云主机天翼云客户服务电话应用编排服务天翼云云安全解决方案云服务总线CSB天翼云服务器配置天翼云联邦学习产品天翼云云安全天翼云企业上云解决方案天翼云产品天翼云视频云存储

      天翼云最新活动

      12.12年度钜惠

      爆款云主机2核2G仅需28.8元/年,X实例35.1元/半年起! 8代机+XSSD新客专享2.5折!

      免费体验DeepSeek,上天翼云息壤

      新老用户均可免费体验2500万Tokens,限时两周

      云上钜惠

      爆款云主机全场特惠,更有万元锦鲤券等你来领!

      算力套餐

      让算力触手可及

      天翼云AI产品特惠

      人脸识别+文字识别焕新,新用户免费试用

      中小企业服务商合作专区

      国家云助力中小企业腾飞,高额上云补贴重磅上线

      出海产品促销专区

      爆款云主机低至2折,高性价比,不限新老速来抢购!

      天翼云电脑专场

      移动办公新选择,爆款4核8G畅享1年3.5折起,快来抢购!

      产品推荐

      弹性云主机

      GPU云主机

      轻量型云主机

      弹性伸缩服务

      弹性高性能计算

      训推服务

      AI Store

      算力互联调度平台

      一站式智算服务平台

      推荐文档

      续订

      手动备份

      创建监控视图

      订购

      文档下载

      提现规则

      MySQL

      • 7*24小时售后
      • 无忧退款
      • 免费备案
      • 专家服务
      售前咨询热线
      400-810-9889转1
      关注天翼云
      • 旗舰店
      • 天翼云APP
      • 天翼云微信公众号
      服务与支持
      • 备案中心
      • 售前咨询
      • 智能客服
      • 自助服务
      • 工单管理
      • 客户公告
      • 涉诈举报
      账户管理
      • 管理中心
      • 订单管理
      • 余额管理
      • 发票管理
      • 充值汇款
      • 续费管理
      快速入口
      • 天翼云旗舰店
      • 文档中心
      • 最新活动
      • 免费试用
      • 信任中心
      • 天翼云学堂
      云网生态
      • 甄选商城
      • 渠道合作
      • 云市场合作
      了解天翼云
      • 关于天翼云
      • 天翼云APP
      • 服务案例
      • 新闻资讯
      • 联系我们
      热门产品
      • 云电脑
      • 弹性云主机
      • 云电脑政企版
      • 天翼云手机
      • 云数据库
      • 对象存储
      • 云硬盘
      • Web应用防火墙
      • 服务器安全卫士
      • CDN加速
      热门推荐
      • 云服务备份
      • 边缘安全加速平台
      • 全站加速
      • 安全加速
      • 云服务器
      • 云主机
      • 智能边缘云
      • 应用编排服务
      • 微服务引擎
      • 共享流量包
      更多推荐
      • web应用防火墙
      • 密钥管理
      • 等保咨询
      • 安全专区
      • 应用运维管理
      • 云日志服务
      • 文档数据库服务
      • 云搜索服务
      • 数据湖探索
      • 数据仓库服务
      友情链接
      • 中国电信集团
      • 189邮箱
      • 天翼企业云盘
      • 天翼云盘
      ©2025 天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
      公司地址:北京市东城区青龙胡同甲1号、3号2幢2层205-32室
      • 用户协议
      • 隐私政策
      • 个人信息保护
      • 法律声明
      备案 京公网安备11010802043424号 京ICP备 2021034386号