活动
天翼云最新优惠活动，涵盖免费试用，产品折扣等，助您降本增效！
热门活动
- 618智算钜惠季 爆款云主机2核4G限时秒杀，88元/年起！
- 免费体验DeepSeek，上天翼云息壤 NEW 新老用户均可免费体验2500万Tokens，限时两周
- 云上钜惠 HOT 爆款云主机全场特惠，更有万元锦鲤券等你来领！
- 算力套餐 HOT 让算力触手可及
- 天翼云脑AOne NEW 连接、保护、办公，All-in-One！
- 中小企业服务商合作专区 国家云助力中小企业腾飞，高额上云补贴重磅上线
- 出海产品促销专区 NEW 爆款云主机低至2折，高性价比，不限新老速来抢购！
- 天翼云电脑专场 HOT 移动办公新选择，爆款4核8G畅享1年3.5折起，快来抢购！
- 天翼云奖励推广计划 加入成为云推官，推荐新用户注册下单得现金奖励
行业应用
合作伙伴
天翼云携手合作伙伴，共创云上生态，合作共赢
开发者
开发者相关功能入口汇聚
消息队列Kafka版_相关内容
- 访问MRS Manager（MRS 2.x及之前版本）3.进入“添加安全组规则”页面,添加需要开放权限用户访问公网的IP地址段并勾选“我确认这里设置的授权对象是可信任的公网访问IP范围,禁止使用0.0.0.0/0,否则会有安全风险。” 默认填充的是用户访问公网的IP地址,用户可根据需要修改IP地址段,如需开放多个IP段为可信范围,请重复执行1-4。如需对安全组规则进行查看,修改和删除操作,请单击“管理安全组规则”。 4.单击“确定”完成安全组规则添加。
- 自定义授权服务*/*", "Host": "httpbin.foo:8000", "User-Agent": "curl/8.2.1", "X-B3-Parentspanid": "eb42a8165099e7db", "X-B3-Sampled": "1", "X-B3-Spanid": "cd6540ba1cfd9e8c", "X-B3-Traceid": "e7e15cc10dc66630eb42a8165099e7db", "X-Envoy-Attempt-Count": "1", "X-Ext-Authz
- Kafka业务迁移如果使用公网地址,则消息生成与消费客户端需要有公网访问权限,并配置如下安全组。 表 安全组规则 方向 协议 端口 源地址 说明 入方向 TCP 9094 0.0.0.0/0 通过公网访问Kafka(关闭SSL加密)。 入方向 TCP 9095 0.0.0.0/0 通过公网访问Kafka(开启SSL加密)。 2、创建Kafka实例 Kafka的规格不能低于原业务使用的Kafka规格。具体请参考购买Kafka实例。
- 配置存算分离集群（委托方式）4.访问OBS文件系统 用root用户登录集群Master节点,具体请参见登录集群节点。 配置环境变量。 MRS 3.x之前版本请执行:source /opt/client/bigdata_env MRS 3.x及之后版本请执行:source /opt/Bigdata/client/bigdata_env 验证Hadoop访问OBS。 a. 查看文件系统mrs-word001下面的文件列表。 hadoop fs -ls obs://mrs-word001/ b.
- 配置存算分离集群（AKSK方式）针对MRS 3.x之前版本,登录集群详情页面,选择“组件管理 > Spark服务配置”。 针对MRS 3.x及之后版本,登录FusionInsight Manager页面,具体请参见访问FusionInsightManager(MRS3.x及之后版本),选择“集群 > 服务 > Spark2x > 配置”。 2.将“基础配置”切换为“全部配置”。 3.选择“JDBCServer > OBS”配置fs.obs.access.key、fs.obs.secret.key参数。
- 查看与手动清除告警针对MRS 3.x之前版本集群,单击“告警ID”、“级别”、“生成时间”可修改排列方式;针对MRS 3.x及以后版本集群,单击“级别”、“生成时间”可修改排列方式。 支持在告警“级别”筛选相同级别的全部告警。结果包含已清除和未清除的告警。 针对MRS 3.x之前版本集群分别单击页面右上角、、或可以快速筛选级别为“致命”、“严重”、“一般”或“提示”的未清除告警。 针对MRS 3.x及之后版本集群分别单击页面右上角、、或可以快速筛选级别为“紧急”、“重要”、“次要”或“提示”的未清除告警。
- 创建Kafka自定义策略本文介绍创建Kafka自定义策略 如果系统预置的Kafka权限,不满足您的授权要求,可以创建自定义策略。自定义策略中可以添加的授权项请参考主子账号和IAM权限管理。 目前天翼云支持可视化视图和JSON视图两种方式设置策略内容,详细介绍请查看统一身份认证-用户指南-权限管理-自定义策略 - 创建自定义策略 可视化视图:通过可视化视图创建自定义策略,无需了解JSON语法,按可视化视图导航栏选择云服务、操作、资源、条件等策略内容,可自动生成策略。
- Kafka Connect接入Kafka本节主要介绍Kafka Connect接入Kafka。 最佳实践概述 场景描述 Kafka Connect可以将完整的数据库注入到Kafka的Topic中,或者将服务器的系统监控指标注入到Kafka,然后像正常的Kafka流处理机制一样进行数据流处理。而导出工作则是将数据从Kafka Topic中导出到其它数据存储系统、查询系统或者离线分析系统等。 如果您想要在流数据平台场景下,使用Kafka Connect快速实现数据从Kafka和其它系统之间进行导入导出,可以参考本实践方案。
- 通过引导操作安装第三方软件该操作适用于MRS 3.x之前版本集群。 MRS 3.x版本暂不支持在创建集群时添加引导操作。 前提条件 已准备好引导操作脚本,详情请参见准备引导操作脚本。 在创建集群时添加引导操作 1.登录MRS管理控制台。 2.单击“创建集群”,进入“创建集群”页面。 3.在创建集群页面,选择“自定义创建”。 4.参考创建自定义集群配置集群软件配置和硬件配置信息。 5.在“高级配置”区域的引导操作栏,单击“添加”。 参数描述 参数 说明 名称 引导操作脚本的名称。
- 使用S3 Java SDK访问OOS本节主要介绍如何通过S3 Java SDK访问OOS。 应用场景 已开通对象存储(经典版)Ⅰ型服务,使用S3 Java SDK访问OOS Bucket和Object。 前提条件 已开通象存储(经典版)Ⅰ型服务,并已创建访问密钥AccessKeyID和SecretAccessKey。 当前AccessKeyID和SecretAccessKey具有OOS相关资源的访问权限。 已创建S3 Java SDK 1.x版本,并能正常使用。
- 管理集群配置针对MRS 2.x及之前版本集群:1. 登录MRS管理控制台。2. 选择“集群列表>现有集群”,单击集群名称进入集群详情页面,单击“组件管理”。3. 单击“下载客户端”。“客户端类型”选择“仅配置文件”,“下载路径”选择“服务器端”或“远端主机”,自定义文件保存路径后,单击“确定”开始生成客户端配置文件。4. 将生成的配置文件,保存到本地路径。 具体可参见MapReduce服务文档-访问FusionInsight Manager(MRS 3.x及之后版本)。 针对MRS 3.x版本集群:1.
- DMS for Kafka自定义策略本文主要介绍 DMS for Kafka自定义策略。 如果系统预置的DMS for Kafka权限,不满足您的授权要求,可以创建自定义策略。 目前云服务平台支持以下两种方式创建自定义策略: 可视化视图创建自定义策略:无需了解策略语法,按可视化视图导航栏选择云服务、操作、资源、条件等策略内容,可自动生成策略。 JSON视图创建自定义策略:可以在选择策略模板后,根据具体需求编辑策略内容;也可以直接在编辑框内编写JSON格式的策略内容。
- 使用Kafka触发器说明开启函数流VPC访问后,需要在Kafka服务安全组配置对应子网的权限。如何开启VPC访问请参见配置网络。Kafka触发器当前支持选择多个Topic主题,从而避免Topic过多导致创建的触发器数量被限制。 配置Kafka事件触发函数。 1、返回函数工作流控制台,在左侧的导航栏选择“函数 > 函数列表”。 2、选择待配置的函数,单击进入函数详情页。 3、在函数详情页,选择函数版本。 4、在“代码”页签下,单击“测试”,弹出“配置测试事件”对话框。 5、填写如下表示测试信息后,单击“保存”。
- 连接和查看Kafka Manager图 Kafka Manager内网访问地址 已开启公网访问时,Kafka Manager地址为“Manager公网访问地址”。 图 Kafka Manager公网访问地址 步骤 3 在浏览器中输入Kafka Manager的地址,进入Kafka Manager登录页面。 如果是开启了公网访问,在本地浏览器输入Kafka Manager地址访问;如果没有开启公网访问,需要登录步骤1的弹性云主机,然后在浏览器输入Kafka Manager地址访问。
- Kafka数据迁移概述表1-1 安全组规则 方向 协议 端口 源地址 说明 入方向 TCP 9094 Kafka客户端所在的IP地址或地址组 通过公网访问Kafka(明文接入)。 入方向 TCP 9095 Kafka客户端所在的IP地址或地址组 通过公网访问Kafka(密文接入)。 创建目标Kafka实例。 目标Kafka的规格不能低于原业务使用的Kafka规格。具体请参考创建Kafka实例。 在目标Kafka实例中创建Topic。
- 修改用户信息说明 该章节操作仅适用于MRS 3.x之前版本集群。MRS3.x及之后版本集群请参考修改用户信息章节。 操作步骤 访问MRS Manager,详细操作请参见访问MRSManager(MRS2.x及之前版本)。 在MRS Manager,单击“系统设置”。 在“权限配置”区域,单击“用户管理”。 在要修改用户所在的行,单击“修改”,修改用户信息。 说明 为用户修改用户组或分配的角色权限,最长可能需要3分钟时间生效。 单击“确定”完成修改操作。
- 解锁用户说明 该章节操作仅适用于MRS 3.x之前版本集群。MRS3.x及之后版本集群请参考解锁用户章节。 操作步骤 访问MRS Manager,详细操作请参见访问MRSManager(MRS2.x及之前版本)。 在MRS Manager,单击“系统设置”。 在“权限配置”区域,单击“用户管理”。 在要解锁用户所在行,选择“解锁用户”,解锁用户。 在弹出的提示窗口,单击“确定”完成解锁操作。
- 连接未开启SASL的Kafka实例图使用内网通过同一个VPC访问Kafka实例的连接地址(实例未开启SASL) 如果是公网访问,实例端口为9094,实例连接地址获取如下图。 图公网访问Kafka实例的连接地址(实例未开启SASL) 3.如果Kafka实例未开启自动创建Topic功能,在连接实例前,请先创建Topic。 4.已下载Kafka命令行工具1.1.0版本或者Kafka命令行工具2.3.0版本或者Kafka命令行工具2.7.2版本,确保Kafka实例版本与命令行工具版本相同。
- Kafka业务迁移Kafka的高性能、可靠性和可扩展性使其成为业务迁移的理想选择。 迁移准备 (1)配置网络环境 Kafka实例分内网地址以及公网地址两种网络连接方式。如果使用公网地址,则消息生成与消费客户端需要有公网访问权限。 (2)创建Kafka实例 Kafka的规格不能低于原业务使用的Kafka规格。 (3)创建Topic 在新的Kafka实例上创建与原Kafka实例相同配置的Topic,包括Topic名称、副本数、分区数、消息老化时间,以及是否同步复制和落盘等。
天翼云最新活动
售前咨询热线
400-810-9889转1
关注天翼云
©2025
天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
公司地址：北京市东城区青龙胡同甲1号、3号2幢2层205-32室
