活动
天翼云最新优惠活动，涵盖免费试用，产品折扣等，助您降本增效！
热门活动
- 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折起，快来抢购！
- 天翼云奖励推广计划 加入成为云推官，推荐新用户注册下单得现金奖励
AI服务
教育应用
合作伙伴
天翼云携手合作伙伴，共创云上生态，合作共赢
消息队列Kafka版_相关内容
- 手工部署RabbitMQ（CentOS 7.4）RabbitMQ是采用Erlang语言实现AMQP(Advanced Message Queuing Protocol,高级消息队列协议)的消息中间件,它最初起源于金融系统,用于在分布式系统中存储转发消息。RabbitMQ凭借其高可靠、易扩展、高可用及丰富的功能特性成为目前非常热门的一款消息中间件。 前提条件 弹性云主机所在安全组添加了如下表所示的安全组规则,具体步骤参见为安全组添加安全组规则。
- 管理消息与新建系统公告此小节介绍云堡垒机管理消息与新建系统公告。 消息中心是系统内各类消息接收提示管理中心。系统公告是对系统用户广播系统内重大变更的消息提醒。 管理消息列表 消息中心小窗可呈现最新三条未读消息。任务执行完成后,则可在任务中心查看全部任务。 消息类型共有5种,分别包括系统消息、业务消息、任务消息、命令告警、工单消息。 消息级别共有3种,分别包括“高”、“中”、“低”,消息级别越高代表消息重要程度越高。 本小节主要介绍如何在消息中心查看、删除、标记消息。 查看消息提醒 登录云堡垒机系统。
- 使用RabbitMQ触发器触发器类型:选择“分布式消息服务RabbitMQ版 (RABBITMQ)”。 实例:选择已创建RabbitMQ实例。 交换机名称:填写用户需要使用的交换机名称。 密码:填写创建RabbitMQ实例的密码。 虚拟机名称:填写用户自定义的vhost。 批处理大小:每次从Topic消费的消息数量。 单击“确定”,完成RabbitMQ触发器的创建。 说明开启函数流VPC访问后,需要在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
- 分布式消息服务RocketMQ事件源图1 创建事件流时选择分布式消息服务RocketMQ作为事件提供方参数说明参数说明示例实例名称前提条件中已创建的分布式消息服务RocketMQ版实例。xxxTopic当前实例中的Topic。topic1Group消费组名。快速创建:自动创建以GID_EVENTBRIDGE_xxx命名的Group ID。使用已有:选择当前实例中已创建的Group,请不要与已有业务的Group混用,以免影响已有的消息收发。group1消费位点开始消费的位置。最新位点:从最新位点开始消费。
- 获取应用消息灰度信息环境参数default请求体body参数 无响应参数参数参数类型说明示例下级对象statusCodeInteger响应编码 2000 suc...消息内容success表 returnObj参数参数类型说明示例下级对象appIdString应用唯一id723df9e5e575bf9e91f4e1axxxxxxenableInteger开关状态 1打开 0关闭1filterSideString消息过滤侧 Client
- 与其他云服务的关系云硬盘(Elastic Volume Service) 云硬盘为云服务器提供块存储服务,Kafka的所有数据(如消息、元数据和日志等)都保存在云硬盘中。 云监控(Cloud Eye) 云监控是一个开放性的监控平台,提供资源的实时监控、告警、通知等服务。 说明 Kafka实例向CloudEye上报监控数据的更新周期为1分钟。 弹性公网IP(Elastic IP) 弹性公网IP提供独立的公网IP资源,包括公网IP地址与公网出口带宽服务。
- RabbitMQ实例规格服务端的性能主要跟以下因素相关:队列数、消息堆积、连接数、channel、消费者数、镜像队列、优先级队列、消息持久化和exchange类型等,在选择实例规格时,请根据业务模型压测结果选择。一条连接最多可以开启2047个channel。
- 创建实例此6个节点可以选择普通版和高级版。 存储空间说明:目前基础版和高级版规格如下: 产品类型 产品规格 高级版本 三节点 8核16GBlvs节点 4核8GB总磁盘范围 300GB – 6000GB 基础版本 三节点 4核8Glvs节点 4核8GB总磁盘范围 300GB – 6000GB 在集群模式中,RabbitMQ需要对消息持久化写入到磁盘中,因为,您在创建RabbitMQ实例选择存储空间时,建议根据业务消息体积预估以及镜像队列副本数量选择合适的存储空间。
- 退订本节主要介绍分布式消息服务Kafka的退订说明 如果您有退订的需求,可以进行登录天翼云管理中心或产品控制台进行退订操作。天翼云目前支持7天无理由全额退订和非七天无理由退订以及其他退订,详细规则请参考文档费用中心-退订。
- 【下线公告】关于天翼云二类节点分布式消息服务RabbitMQ下线部分插件的公告rabbitmq_web_stomp插件通过临时队列提供WebSocket能力,同时其连接和释放依赖于心跳机制,过多的临时队列以及过多连接数会导致内存高水位,从而导致节点状态异常。下线影响未开启待下线插件的实例,插件列表中将不再显示这些插件。已开启待下线插件的实例,仍然可以使用。如果您在控制台关闭这些插件后,也将不再显示。如有任何问题可通过天翼云官网(www.ctyun.cn)提交工单或服务热线(4008109889)与我们联系。
- 步骤一：准备环境对应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全局是是是是有分布式消息服务
- KafkaProducer监控recordSendTotal总发送次数总发送次数-INTSUMbyteTotal总发送字节数总发送字节数-INTSUM异常 (except...kafka发送异常信息。)causeType异常发生类异常发生类-ENUMLASTexceptionType异常类异常类-ENUMLASTcount数量异常数量-INTSUMmessage异常消息异常消息-STRINGLASTstackTrace异常堆栈异常堆栈-CLOBLAST发送方法(doSendMethod,发送消息方法监控。)
- 手工部署RabbitMQ（CentOS 7.4）RabbitMQ是采用Erlang语言实现AMQP(Advanced Message Queuing Protocol,高级消息队列协议)的消息中间件,它最初起源于金融系统,用于在分布式系统中存储转发消息。RabbitMQ凭借其高可靠、易扩展、高可用及丰富的功能特性成为目前非常热门的一款消息中间件。 前提条件 弹性云主机所在安全组添加了如下表所示的安全组规则。
- KafkaProducer介绍APM监控详情里消息监控中的KafkaProducer相关指标的名称、含义等信息。
- 程序日志定位告警异常本小节介绍日志审计(原生版)场景下的程序日志定位告警异常处理实践。 应用场景日志审计(原生版)已经采集到日志,但未触发对应告警。前提准备进入日志审计(原生版)平台。通过控制台进入日志审计(原生版)实例。告警服务逻辑告警涉及服务:esinsert、alarmMgr、event_analysvr。告警涉及流程:event_ana(告警解析):通过Kafka接收logp解析的日志,根据告警规则解析该日志是否符合告警条件,符合条件则将该告警信息转发给alarm。
- 相关术语解释本章节介绍了分布式消息服务RocketMQ的相关术语解释。 主题(Topic) 消息关联的基础逻辑单元。消息生产与消费时的基础单位。 队列(Queue) 一个主题由多个队列组成。队列数越大消费的并发度越大。 生产者(Producer) 消息写入的触发者,负责将消息推送到服务端。 生产者组(Producer Group) 同一类生产者的集合,这类生产者发送同一类消息且发送逻辑一致。 消费者(Consumer) 接收消息的对象,负责从服务端获取消息。
- 使用限制介绍分布式消息服务Kafka产品功能的使用限制。 限制项 使用说明 实例 开通后,不支持修改VPC/子网/可用区,不支持变更地域属性 扩缩容 当前只支持节点、规格、磁盘扩容,不支持缩容 版本 当前服务端版本为2.13-2.8.2。
天翼云最新活动
售前咨询热线
400-810-9889转1
关注天翼云
©2025
天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
公司地址：北京市东城区青龙胡同甲1号、3号2幢2层205-32室
