检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
消费者的消费能力不足（消费者并发低、消息处理时间长），导致消费效率低于生产效率。 消费者异常（如消费者故障、消费者网络异常等）导致无法消费消息。 Topic分区设置不合理，或新增分区无消费者消费。 Topic频繁重平衡导致消费效率降低。 实施步骤 从消息堆积的原因看，消息堆积问题可以从消费者端、生产者端和服务端三个方面进行处理。
变量修改 “变量修改”处理器用于修改前置“变量赋值”节点创建的变量的值。一个“变量修改”节点中可以更新多个变量。 配置参数 参数 说明 选择变量 选择前置“变量赋值”处理器中创建的变量。 变量值 填写修改后的变量值。变量值可以是一个常量，如“hello world”，也可以使用表达式引用前序步骤的变量，例如
String 部署到前端的api归属的应用编号，与后端归属的应用编号保持一致 响应参数 状态码： 200 表4 响应Body参数 参数 参数类型 描述 id String 部署的编号 ld_api_id String 部署的后端API编号 group_id String 部署的前端API分组编号
选择“MySql”连接器。 在弹窗中配置连接器信息，完成后单击“确定”。 参数 说明 连接名称 填写连接器实例名称。 区域 选择区域。 项目 选择项目。 实例 选择实例，用于后续验证连通性。 连接与安全 选择数据库的连接模式。当前支持“默认”模式，由系统根据用户配置自动拼接数据源连接字符串。
OBS数据源的接入配置示例如下图所示。 图1 OBS数据源配置示例 完成数据源接入配置后，单击“开始检测”，检测ROMA Connect与数据源之间是否能够连通。 若测试结果为“数据源连接成功！”，则继续下一步。 若测试结果为“数据源连接失败！”，则检查数据源状态和数据源连接参数配置，然后单击“重新检测”，直到连接成功为止。
接入数据源 概述 在创建数据API之前，您需要先接入数据源，确保可以正常从数据源读取数据。根据数据源类型的不同，数据源的接入配置有所差异。 前提条件 在接入数据源前，请确保ROMA Connect实例与您的数据源所在网络互通。 若ROMA Connect实例与数据源在相同VPC内时，可直接访问数据源。
名进行API调用测试，ROMA Connect对默认子域名的访问次数做了限制，每天最多可以访问1000次。 配置API授权（可选） 仅使用APP认证方式的API，才需要配置调用授权，把API授权给指定集成应用，用户使用集成应用的Key和Secret进行API请求的安全认证。 创建并开放数据API
String 部署的编号 ld_api_id String 部署的后端API编号 group_id String 部署的前端API分组编号 env_id String 部署的环境编号 api_id String 部署的前端API编号 deploy_time String 部署时间 api_definition
接入数据源 概述 在创建数据API之前，您需要先接入数据源，确保可以正常从数据源读取数据。根据数据源类型的不同，数据源的接入配置有所差异。 前提条件 在接入数据源前，请确保ROMA Connect实例与您的数据源所在网络互通。 若ROMA Connect实例与数据源在相同VPC内时，可直接访问数据源。
数据转换 “数据转换”连接器用于数据流的格式转换，当前支持XML转JSON和JSON转XML。 配置参数 参数 说明 转换模式 选择数据转换的模式，可选择“XML转JSON”和“JSON转XML”。 内容 通过脚本编写需要转换的数据。 可通过变量的方式引用前序步骤中的数据，请参考引用变量。
本文以Linux CentOS环境为例，介绍Go版本的Kafka客户端连接指导，包括Kafka客户端安装，以及生产、消费消息。 前提条件 已获取MQS连接信息，具体请参见开发准备。 已安装开发工具和Python开发语言环境，具体请参见开发准备。 引入Kafka客户端 MQS基于Kafka社区版本1
在“分组信息”页签的“环境变量”下，“环境”参数选择要添加变量的环境，然后单击“添加环境变量”。 在新增变量弹窗中配置环境变量信息，完成后单击“确定”。 表2 环境变量配置 参数 说明 变量名称 填写变量的名称，必须与API后端服务信息中定义的环境变量一致。 变量值 填写环境变量的值。
在左侧的导航栏选择“服务集成 APIC > API管理”，在“API分组”页签中单击“创建分组”。 在创建分组弹窗中配置API分组相关信息，然后单击“确定”，创建API分组。 表1 API分组配置 参数 配置说明 分组名称 填写API分组的名称，根据规划自定义。建议您按照一定的命名规则填写API分组名称，方便您快速识别和查找。
debug，且API配置了API流量控制时，返回此参数 X-Apig-RateLimit-user 用户流量限制信息 示例：remain:9,limit:10,time:10 second 仅在请求消息头包含X-Apig-Mode: debug，且API配置了用户流量限制时，返回此参数
7：初始化失败 8：注册失败 10：安装中 11：安装失败 12：升级中 13：升级失败 20：回滚中 21：回滚成功 22：回滚失败 23：删除中 24：删除失败 25：注销中 26：注销失败 27：创建超时 28：初始化超时 29：注册超时 30：安装超时 31：升级超时 32：回滚超时
排序 “排序”处理器用于处理数据的排序。 配置参数 参数 说明 数据集 待排序的数据，可以是上一步传过来的数据，也可以是自定义的数据。 可通过变量的方式引用前序步骤中的数据，请参考引用变量。 参数路径 排序使用的参数。 可通过变量的方式引用前序步骤中的数据，请参考引用变量。 排序方式
“XML校验”处理器用于对XML格式数据处理时，进行内容校验与处理。如校验正确在系统日志中没有错误信息，校验失败系统日志中会打印异常信息，并结束流任务的运行。 配置参数 参数 说明 XML 待校验的xml数据，文本输入大小限制10万字符。 XML Schemas Definition xsd格式的校验
在左侧的导航栏选择“服务集成 APIC > 自定义后端”，在“后端列表”页签上方单击“导入后端”。 在导入后端页面中，配置导入相关信息。 表1 导入自定义后端 参数 配置说明 API定义覆盖 当导入的自定义后端与已有的自定义后端定义冲突时，是否使用导入的自定义后端覆盖已有的自定义后端。
变量赋值 “变量赋值”处理器用于创建变量，后续步骤中可使用这些变量。一个“变量赋值”节点中可以创建多个变量。 配置参数 参数 说明 变量名 填写变量的名称。 变量类型 选择变量的类型，目前支持字符串、整数、长整数、小数、布尔和对象。 变量值 填写变量的值。变量值可以是一个常量，如“hello
debug，且API配置了API流量控制时，返回此参数 X-Apig-RateLimit-user 用户流量限制信息 示例：remain:9,limit:10,time:10 second 仅在请求消息头包含X-Apig-Mode: debug，且API配置了用户流量限制时，返回此参数
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
