活动
天翼云最新优惠活动，涵盖免费试用，产品折扣等，助您降本增效！
热门活动
- 11.11智惠上云月 NEW 爆款云主机2核2G28.8元/年起！更有限时续费优惠，最低3.5折！
- 免费体验DeepSeek，上天翼云息壤 NEW 新老用户均可免费体验2500万Tokens，限时两周
- 云上钜惠 HOT 爆款云主机全场特惠，更有万元锦鲤券等你来领！
- 算力套餐 HOT 让算力触手可及
- 天翼云AI产品特惠 NEW 人脸识别+文字识别焕新，新用户免费试用
- 中小企业服务商合作专区 国家云助力中小企业腾飞，高额上云补贴重磅上线
- 出海产品促销专区 NEW 爆款云主机低至2折，高性价比，不限新老速来抢购！
- 天翼云电脑专场 HOT 移动办公新选择，爆款4核8G畅享1年3.5折起，快来抢购！
- 天翼云奖励推广计划 加入成为云推官，推荐新用户注册下单得现金奖励
AI服务
教育应用
合作伙伴
天翼云携手合作伙伴，共创云上生态，合作共赢
消息队列Kafka版_相关内容
- 创建实例此6个节点可以选择普通版和高级版。 存储空间说明:目前基础版和高级版规格如下: 产品类型 产品规格 高级版本 三节点 8核16GBlvs节点 4核8GB总磁盘范围 300GB – 6000GB 基础版本 三节点 4核8Glvs节点 4核8GB总磁盘范围 300GB – 6000GB 在集群模式中,RabbitMQ需要对消息持久化写入到磁盘中,因为,您在创建RabbitMQ实例选择存储空间时,建议根据业务消息体积预估以及镜像队列副本数量选择合适的存储空间。
- 与其他云服务的关系云硬盘(Elastic Volume Service) 云硬盘为云服务器提供块存储服务,Kafka的所有数据(如消息、元数据和日志等)都保存在云硬盘中。 云监控(Cloud Eye) 云监控是一个开放性的监控平台,提供资源的实时监控、告警、通知等服务。 说明 Kafka实例向CloudEye上报监控数据的更新周期为1分钟。 弹性公网IP(Elastic IP) 弹性公网IP提供独立的公网IP资源,包括公网IP地址与公网出口带宽服务。
- 相关术语解释本章节介绍了分布式消息服务RocketMQ的相关术语解释。 主题(Topic) 消息关联的基础逻辑单元。消息生产与消费时的基础单位。 队列(Queue) 一个主题由多个队列组成。队列数越大消费的并发度越大。 生产者(Producer) 消息写入的触发者,负责将消息推送到服务端。 生产者组(Producer Group) 同一类生产者的集合,这类生产者发送同一类消息且发送逻辑一致。 消费者(Consumer) 接收消息的对象,负责从服务端获取消息。
- 步骤一：准备环境对应1.1.0版本实例的下载地址:https://archive.apache.org/dist/kafka/1.1.0/kafka_2.11-1.1.0.tgz wget https://archive.apache.org/dist/kafka/1.1.0/kafka_2.11-1.1.0.tgz 对应2.3.0版本实例的下载地址:https://archive.apache.org/dist/kafka/2.3.0/kafka_2.11-2.3.0.tgz wget https://archive.apache.org
- 使用IAM授权的云服务全局是否否否有云专线全局是是否否有VPN连接资源池是是是是有天翼云SD-WAN全局是是否否有云终端云服务名称区域控制台OpenAPI系统策略...版)全局是是是是有天翼云手机全局是是是是有CDN与边缘云服务类别区域控制台OpenAPI系统策略支持IAM支持企业项目支持IAM支持企业项目边缘安全加速平台全局是是是是有容器与中间件云服务名称区域 控制台OpenAPI系统策略支持IAM支持企业项目支持IAM支持企业项目分布式消息服务Kafka全局是是是是有分布式消息服务
- 手工部署RabbitMQ（CentOS 7.4）RabbitMQ是采用Erlang语言实现AMQP(Advanced Message Queuing Protocol,高级消息队列协议)的消息中间件,它最初起源于金融系统,用于在分布式系统中存储转发消息。RabbitMQ凭借其高可靠、易扩展、高可用及丰富的功能特性成为目前非常热门的一款消息中间件。 前提条件 弹性云主机所在安全组添加了如下表所示的安全组规则。
- 消费Kafka Topic时报错“Not Authorized to access group XXX”如何处理？本章节主要介绍翼MapReduce组件Kafka作业的常见问题。 该报错是由于kafka消费者组缺少ACL授权导致的。 可以通过如下命令赋予消费者组XXX读取权限: ./kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181/kafka --add --allow-principal User:UserName --operation Read --group XXX
- 程序日志定位告警异常本小节介绍日志审计(原生版)场景下的程序日志定位告警异常处理实践。 应用场景日志审计(原生版)已经采集到日志,但未触发对应告警。前提准备进入日志审计(原生版)平台。通过控制台进入日志审计(原生版)实例。告警服务逻辑告警涉及服务:esinsert、alarmMgr、event_analysvr。告警涉及流程:event_ana(告警解析):通过Kafka接收logp解析的日志,根据告警规则解析该日志是否符合告警条件,符合条件则将该告警信息转发给alarm。
- topic、queue的规划在Push消费模式中,API会默认为每个队列预拉取消息1000条,若队列数过大、或者单条消息包体过大,则需要考虑设置减少预拉数量,防止预拉消息过大导致内存溢出。
- 退订本节主要介绍分布式消息服务Kafka的退订说明 如果您有退订的需求,可以进行登录天翼云管理中心或产品控制台进行退订操作。天翼云目前支持7天无理由全额退订和非七天无理由退订以及其他退订,详细规则请参考文档费用中心-退订。
- KafkaProducer监控recordSendTotal总发送次数总发送次数-INTSUMbyteTotal总发送字节数总发送字节数-INTSUM异常 (except...kafka发送异常信息。)causeType异常发生类异常发生类-ENUMLASTexceptionType异常类异常类-ENUMLASTcount数量异常数量-INTSUMmessage异常消息异常消息-STRINGLASTstackTrace异常堆栈异常堆栈-CLOBLAST发送方法(doSendMethod,发送消息方法监控。)
- 名词解释普通有序消息 有序消息的一种,在正常情况下可以保证完全的顺序消息,但是一旦发生通信异常,Broker重启,由于队列总数发生变化,哈希取模后定位的队列会变化,产生短暂的消息顺序不一致。如果业务能容忍在集群异常情况(如某个Broker宕机或者重启)下,消息短暂的乱序,使用普通顺序方式比较合适。 严格有序消息 有序消息的一种。
- KafkaProducer介绍APM监控详情里消息监控中的KafkaProducer相关指标的名称、含义等信息。
- 交换器管理其他参数 Alternate exchange:备份交换器是为了实现没有路由到队列的消息,声明交换机的时候添加属性alternate-exchange,声明一个备用交换机,一般声明为fanout类型,这样交换机收到路由不到队列的消息就会发送到备用交换机绑定的队列中。 其中交换机类型如下表所示 交换机类型 说明 Direct 完全根据key进行投递的叫做Direct交换机。如果Routing key匹配, 那么Message就会被传递到相应的queue中。
- RabbitMQ业务迁移图5 shovel完成状态 说明 shovel迁移数据的原理是消费线下实例消息,生产消息到线上实例,迁移后线下实例消息 被清空,建议离线迁移,业务会出现中断。确保线上实例和线下实例可连通。 通过以下方法,确认数据是否迁移完成。 在RabbitMQ WebUI页面查看,如图6所示。 Overview视图中,线下实例中可消费消息数(Ready)以及未确认的消息数(Unacked)都为0时,说明迁移完成。 图6 RabbitMQ WebUI 针对于具体的队列数据,可以进队列页面查看。
- 集群版客户端常见错误码有哪些？本文介绍Redis集群版客户端常见错误码 50010001:路由队列堵塞。 50010002:添加路由队列异常。 50010003: 路由处理异常。 50010004:注册客户端读失败。 50010005:超过允许的最大客户端连接数。 50010006:注册目标路由读事件异常。 50010007:单个客户端连接请求数大于规定值。 50010008:协议异常,一般为客户端发送了不支持的命令或者断开连接。 50010009:不完整的报文。 50010010:读取redis超时。
- Java客户端Pull和Push的选择：Java客户端必须使用Push ConsumerPush会自动订阅重试队列,不需要再次调用拉取重试队列的API来取得重试队列的消息(备注:Pull需要另外调用API拉取重试队列的消息)。 Pull是一种遗留的消费模式(兼容早期的API),新开发的应用,或者未上线的应用,都要求使用Push消费模式。
- 程序定位日志采集异常本小节介绍日志审计(原生版)场景下的定位日志采集异常处理实践。 应用场景有产生日志,但日志审计(原生版)平台未看到该日志,如何定位问题。前提准备通过控制台进入日志审计(原生版)实例。日志采集涉及服务逻辑日志采集涉及服务:log_c、logp、coresvr、esinset。日志采集涉及流程:Log_c(日志采集)接收日志并通过kafka将接收的日志转发log_p。Log_p(日志解析分类)接收log_c转发的原始日志根据解析规则等进行解析,并通过kafka将解析后的日志发送给esinsert。
- 使用限制介绍分布式消息服务Kafka产品功能的使用限制。 限制项 使用说明 实例 开通后,不支持修改VPC/子网/可用区,不支持变更地域属性 扩缩容 当前只支持节点、规格、磁盘扩容,不支持缩容 版本 当前服务端版本为2.13-2.8.2。
- 如何排查日志未采集？本小节介绍日志审计(原生版)产品排查日志未采集常见问题。 如何排查日志未采集? 问题描述 日志审计(原生版)采集日志配置配好后,仍未采集到日志,如何排查? 可能原因 采集日志相关程序未正常启动。 中间件出现故障。 采集资产未配置。 解决方案 了解采集日志程序作用 Log_c(日志采集)接收日志并通过kafka将接收的日志转发log_p。 Log_p(日志解析分类)接收log_c转发的原始日志根据解析规则等进行解析,并通过kafka将解析后的日志发送给esinsert。
- 入门实践本文主要介绍分布式消息服务RabbitMQ的入门实践。 当您购买了RabbitMQ实例后,可以根据自身的业务需求使用分布式消息服务RabbitMQ提供的一系列常用实践。 表1 常用最佳实践 实践描述RabbitMQ业务迁移介绍将线下单机或集群实例迁移到天翼云RabbitMQ实例的方案。RabbitMQ队列迁移扩容节点、删除队列可能会导致队列在各个节点分布不均衡,本文介绍如何设置队列负载均衡。
天翼云最新活动
售前咨询热线
400-810-9889转1
关注天翼云
©2025
天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
公司地址：北京市东城区青龙胡同甲1号、3号2幢2层205-32室
