活动
天翼云最新优惠活动，涵盖免费试用，产品折扣等，助您降本增效！
热门活动
- 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版_相关内容
- 自定义分布式消息服务RocketMQ事件源在添加自定义事件源面板,输入名称和描述,事件提供方选择分布式消息服务RocketMQ,选择实例、主题等配置然后单击确认,如图1所示。图1 创建事件源时事件提供方选择分布式消息服务RocketMQ参数说明参数说明示例 名称 事件源名。source1实例名称选择前提条件中已创建的分布式消息服务RocketMQ版实例。xxx Topic选择当前实例中的Topic。topic1Group快速创建:自动创建以GID_EVENTBRIDGE_xxx命名的Group ID。
- 交换器管理其他参数 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 针对于具体的队列数据,可以进队列页面查看。
- Java客户端Pull和Push的选择：Java客户端必须使用Push ConsumerPush会自动订阅重试队列,不需要再次调用拉取重试队列的API来取得重试队列的消息(备注:Pull需要另外调用API拉取重试队列的消息)。 Pull是一种遗留的消费模式(兼容早期的API),新开发的应用,或者未上线的应用,都要求使用Push消费模式。
- 购买类集群可用的场景只有50%,所以不支持选择2个可用区如何选择Kafka实例的存储空间?存储空间,主要是指用于存储消息所需要的空间,选择时包括选择磁盘规格和大小,磁盘规格,当前支持“超高IO”和“高IO”两种类型。假设业务存储数据保留天数内磁盘大小为100GB,则磁盘容量最少为100GB*副本数 + 预留磁盘大小100GB。Kafka集群中,每个Kafka节点会使用33G的磁盘作为日志和Zookeeper数据的存储,因而实际可用存储会小于购买存储。
- 搭建微信公众号后台——收发文本消息本文主要介绍如何搭建微信公众号后台——收发文本消息。 概述 在本教程中,您将学会使用弹性云主机(以下简称 ECS)搭建微信公众号处理后台,使用Python语言编写对应的微信消息处理逻辑代码,接收从微信服务端转发过来的消息,并返回处理结果给最终用户。 您需要了解的背景知识有: CentOS(Linux)操作系统、Python语言、Web.py框架、HTTP/XML协议。
- ALM-38006 Kafka未完全同步的Partition百分比超过阈值对系统的影响 Kafka服务未完全同步的Partition数过多,会影响服务的可靠性,一旦发生leader切换,可能会导致丢数据。 可能原因 部分Broker实例所在节点故障或者实例停止运行,导致Kafka中某些Partition的副本下线。 处理步骤 检查Broker实例 在FusionInsight Manager首页,选择“集群 > 待操作集群的名称 > 服务 > Kafka > 实例”,进入Kafka实例页面。 查看所有Broker实例中是否有故障的节点。
- 入门实践本文主要介绍分布式消息服务RabbitMQ的入门实践。 当您购买了RabbitMQ实例后,可以根据自身的业务需求使用分布式消息服务RabbitMQ提供的一系列常用实践。 表1 常用最佳实践 实践描述RabbitMQ业务迁移介绍将线下单机或集群实例迁移到天翼云RabbitMQ实例的方案。RabbitMQ队列迁移扩容节点、删除队列可能会导致队列在各个节点分布不均衡,本文介绍如何设置队列负载均衡。
- ALM-38009 Broker磁盘IO繁忙数据目录名称 Kafka磁盘IO频繁的数据目录名称 对系统的影响 Partition所在的磁盘分区IO过于繁忙,产生告警的Kafka Topic上可能无法写入数据。 可能原因 Topic副本数配置过多。 生产者消息批量写入磁盘的参数设置不合理。该Topic承担的业务流量过大,当前Partition的设置不合理。
- Capacity Scheduler模式下清除租户非关联队列本章节主要介绍翼MapReduce的Capacity Scheduler模式下清除租户非关联队列操作。 操作场景 在Yarn Capacity Scheduler模式下,删除租户的时候,只是把租户队列的容量设置为0,并且把状态设为“STOPPED”,但是队列在Yarn的服务里面仍然残留。由于Yarn的机制,无法动态删除队列,管理员可以执行命令手动清除残留的队列。 对系统的影响 脚本运行过程中会重启controller服务,同步Yarn的配置,并重启主备ResourceManager实例。
- 产品定义灵活路由 在RabbitMQ中,生产者将消息发送到交换器,由交换器将消息路由到队列中。交换器支持Direct、Topic、Headers和Fanout四种路由方式,同时支持交换机组合和自定义。 高可用 RabbitMQ集群提供镜像队列,可通过镜像在其他节点同步数据,单节点宕机时,仍可通过唯一的访问地址对外提供服务,数据不丢失。 监控和告警 支持对RabbitMQ实例状态进行监控,支持对集群每个代理的内存、CPU、网络流量等进行监控。如果集群或节点状态异常,将触发告警。
- Topic管理操作步骤 登录分布式消息服务RocketMQ控制台。 单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,单击“Topic管理”,进入“Topic管理”页面。 单击需要查询的Topic名称,进入Topic详情页面。 在详情页上方可以查看Topic名称、关联代理、读队列个数、写队列个数和权限。 在详情页下方可以查看Topic在每个代理上的队列状态,包括队列ID、最小偏移量、最大偏移量和消息更新时间。还可以查看消费组消费此Topic的情况,包括消费组名称、最大重试次数和广播消费。
- Kubernetes 1.29版本说明本文介绍了:云容器引擎发布Kubernetes 1.29版本说明。 社区 Kubernetes 版本主要变更Kubernetes 1.29 版本ChangelogKubernetes 1.29 版本,API 优先级和公平性(AFP)正式 GA,该特性以更细粒度的方式对请求进行分类和隔离。它还引入了有限的排队量,因此在非常短暂的突发情况下不会拒绝任何请求。请求使用公平排队技术从队列中分派,例如,行为不佳的控制器不会影响其他控制器(即使在相同的优先级)。
- 分布式消息服务RabbitMQ分布式消息服务RabbitMQ是基于高可用、分布式集群技术,完全兼容RabbitMQ开源社区,支持消息路由、事务消息、优先级队列、延迟队列、死信队列、镜像队列等功能的消息云服务。用户可开箱即用,无需部署免运维,从而实现快速上云。
- 默认权限信息一览集群默认用户组 kafka Kafka普通用户组。添加入本组的用户,需要被kafkaadmin组用户授予特定Topic的读写权限,才能访问对应Topic。 集群默认用户组 kafkaadmin Kafka管理员用户组。添加入本组的用户,拥有所有Topic的创建,删除,授权及读写权限。 集群默认用户组 kafkasuperuser Kafka的Topic读写用户组。添加入本组的用户,拥有所有Topic的读写权限。
- 如何配置客户端参数？本节介绍分布式消息服务Kafka客户端参数配置 根据实际业务场景,客户端参数配置适当的值,客户端参数列表及说明如下所示: 表1.生产者客户端 参数 说明 retries 消息发送失败时的重试次数。 retry.backoff.ms 消息发送失败时的重试间隔,建议设置为1000。单位:毫秒。 acks 发送消息的持久化机制。为了提升发送性能, 建议设置为acks=1。acks=0:无需服务端的Response,性能较高、丢数据风险较大。
- 用户管理背景信息 客户端访问分布式消息服务RabbitMQ 版服务端时,需要传入用户名和密码进行权限认证,认证通过才允许访问服务端。 操作步骤 创建用户 1.登录管理控制台。 2.进入RabbitMQ管理控制台。 3.在实例列表页在操作列,目标实例行点击“管理”。 4.点击“集群管理”后点击“用户”到达用户管理页面,点击“新建”按钮。 5.点击“新建”后出现以下画面,输入用户密码后点击“确定”即可创建。 修改用户 1.在用户管理页面,在目标用户行点击“修改”,即可重置用户密码。
天翼云最新活动
售前咨询热线
400-810-9889转1
关注天翼云
©2025
天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
公司地址：北京市东城区青龙胡同甲1号、3号2幢2层205-32室
