检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
导入Api的请求体，json或yaml格式的文件 响应参数 状态码： 200 表4 响应Body参数 参数 参数类型 描述 success Array of Success objects 导入成功信息 failure Array of Failure objects 导入失败信息 swagger
描述 topic 是 String Topic名称。 partition 否 Integer 分区编号，默认值为-1，若传入值为-1，则重置所有分区。 message_offset 否 Integer 重置消费进度到指定偏移量。 如果传入offset小于当前最小的offset，则重置到最小的offset。
参数类型 描述 success Array of Success objects 导入成功信息 failure Array of Failure objects 导入失败信息 swagger Swagger object swagger文档导入结果 暂不支持 表5 Success 参数 参数类型
认证，其安全性比Token认证要高。 Token认证：通过Token认证通用请求。 AK/SK认证：通过AK（Access Key ID）/SK（Secret Access Key)加密调用请求。 Token认证 Token的有效期为24小时，需要使用一个Token鉴权时，可以先缓存起来，避免频繁调用。
创建函数后端 ROMA Connect支持把自定义函数定义为后端服务，把函数的能力以API的形式对外开放。 前提条件 如果后端服务需要使用签名密钥请求发送方进行认证，请提前创建签名密钥。 操作步骤 登录ROMA Connect控制台，在“实例”页面单击实例上的“查看控制台”，进入实例控制台。
导出Topic。 导出指定Topic：勾选您想要导出的Topic，然后单击“批量操作 > 导出Topic”，导出Topic文件到本地。 导出所有Topic：单击“导出所有Topic”，导出Topic文件到本地。 在导出Topic弹窗中选择要导出文件的格式，然后单击“导出”，导出Topic文件到本地。
起点以新版ROMA Connect实例创建成功的时间点为准，终点以实例删除时间点的小时整点为准。 新版ROMA Connect实例从创建到启动需要一定时长，计费的起点是创建成功的时间点，而非创建时间。 计费示例 假设您在2023/10/16 9:30:00创建成功了一个按需计费的新版ROMA
JSON2XMLHelper类说明 路径 com.huawei.livedata.util.JSON2XMLHelper 说明 提供Json与Xml之间的相互转换。 方法列表 返回类型 方法和说明 static String JSON2XML(String json, boolean
{ "id" : "topic-mqs-test1", "success" : true }, { "id" : "topic-mqs-test2", "success" : true } ] } 状态码： 400 Bad Request {
"隔开)。 最小长度：0 最大长度：256 ak 否 String Access Key ID。 数据源为OBS，DIS类型时需要配置。 最小长度：0 最大长度：256 sk 否 String Secret Access Key。 数据源为OBS，DIS类型时需要配置。 最小长度：0
户端IP地址或IP地址段。 完成后单击“确定”，完成访问控制策略设置。 访问控制策略设置后，您可以在设置访问控制策略界面单击“重置”，清除所有访问控制策略。 父主题： 控制策略管理
new.pod.port,feature.physerver.kafka.topic.modify,feature.physerver.kafka.topic.accesspolicy,message_trace_enable,features.pod.token.access,rabbitmq
固定为“HTTP响应头管理”。 可见范围 选择策略的可见范围。 集成应用：策略归属某个集成应用，仅拥有该集成应用权限的用户可查看和使用该策略。 全局：当前实例的所有用户都可查看和使用该策略。 集成应用 仅当“可见范围”选择“集成应用”时需要配置。 选择策略所属的集成应用。若没有可用的集成应用，可单击右
microservice_port 否 Integer VPC通道后端服务器组的端口号，仅VPC通道类型为微服务时支持。端口号为0时后端服务器组下的所有地址沿用原来负载端口继承逻辑。 最小值：0 最大值：65535 microservice_labels 否 Array of MicroserviceLabel
IAM认证开发（AK/SK） 使用AK（Access Key ID）、SK（Secret Access Key）对请求进行签名。 AK：访问密钥ID。与私有访问密钥关联的唯一标识符，访问密钥ID和私有访问密钥一起使用，对请求进行加密签名。 SK：与访问密钥ID结合使用的密钥，对请
Empty：消费组内没有任何成员，存在元数据。 PreparingRebalance：准备开启rebalance。 CompletingRebalance：所有成员加入group。 Stable：消费组内成员可正常消费。 coordinator_id Integer 协调器编号。 members Array
private String hmac() { return "Hmac authorization success"; } } 编写一个Filter，匹配所有路径和方法。将允许的签名key和secret对放入一个Map中。 public class ApigatewaySignatureFilter
the Creating, Starting or Restarting state cannot be deleted. 实例状态为创建中、启动中、停止中、重启中时不允许执行删除操作。 请检查实例状态。 400 MQS.00400100 The number of instance
Connect服务控制台创建一个ROMA Connect实例，实例规格配置根据实际业务情况选择。 创建集成应用。 在实例控制台创建一个集成应用，实例中的所有资源都要有归属的集成应用。 根据不同的业务场景，选择使用不同ROMA Connect功能。 数据集成：接入源端和目标端数据源，然后通过集成任务进行源端到目标端的数据集成。
topic.accesspolicy,rabbitmq.plugin.management,roma_app_enable,auto_topic_switch,feature.physerver.kafka.user.manager,route,kafka.new.pod.port,feature
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
