检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
因为该API未定义请求参数，在调试API页面中直接单击API URL右侧的“调试”，进行API调用测试。 在页面下方可查看调用API发送的请求消息及响应消息。 若调用成功，则会返回成功响应消息体。此处的成功响应消息应为“ROMA TEST!”。 图6 API调试 调试完成后，单击“调试”按钮右侧的“”，返回API的详情信息页面。
APP认证（双重认证） 同时获取APP认证以及自定义认证所需的认证信息。 IAM认证（Token认证） 获取云服务平台的用户账号密码。 IAM认证（AK/SK认证） 获取云服务平台的用户账号的AK/SK，以及认证签名所使用的SDK。 IAM认证（双重认证） 同时获取IAM认证以及自定义认证所需的认证信息。
使用Kafka客户端内网连接MQS：在“连接地址”下查看消息集成 MQS内网连接地址。 使用Kafka客户端公网连接MQS：在“连接地址”下查看消息集成 MQS公网连接地址。 使用RESTful API连接MQS：在“MQS基本信息”下查看消息RESTful API。 获取Topic名称 在ROMA
新增数据标准，单击“上架”。 同步数据标准 在左侧的导航栏选择“应用业务模型ABM > 业务术语 > 术语管理”，单击添加分组，添加第三方分组。 选择已创建的第三方分组，单击“数据同步”按钮，“数据来源”选择之前创建的类型数据源，执行数据同步。同步获取的DataArts Studio数据标准，可在“模型地图”中检索。
pic。 在下方的消息输入框中填写Json格式的消息内容。 图8 设备发送消息 在ROMA Connect实例控制台选择“消息集成MQS > 消息查询”，进入消息查询页面。 单击“高级搜索”展开高级搜索框。 输入搜索条件，然后单击“搜索”，查询客户端发送的消息记录。 “Topic
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 响应参数 状态码： 200 表4 响应Body参数 参数 参数类型 描述 broker_name
Connect的消息集成MQS完全兼容开源Kafka协议，业务应用需要开发并集成开源Kafka客户端或ROMA Connect提供的RESTful API，实现与MQS的消息连接。 集成开源客户端：业务应用直接集成开源Kafka客户端，并通过客户端连接MQS，实现消息的生产和消费。
端版本主要为2.x.x版本，而ROMA Connect消息集成的Kafka服务端版本为1.1.0、2.7版本。因此在Spring Boot项目工程中使用spring-kafka连接ROMA Connect时，请确保客户端与服务端的Kafka版本一致。 若spring-kafka连接的ROMA
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 task
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 响应参数 无 请求示例 GET https://{endpoint}/v2/
开启：触发降级的API将把请求转发到指定后端服务。 关闭：触发降级的API不会把请求转发到任何后端服务，直接返回服务不可用的错误信息。 后端策略类型 仅当“后端降级策略”开启时需配置。 断路器开启后，后端请求的转发策略类型。 Mock：把配置的响应结果作为后端服务响应固定返回。 Mock自定义返回码：后端服务响应的状态码。
查询所有消费组 功能介绍 查询所有消费组。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET /v2/{project_id}/mqs/instances/{instance_id}/groups
开发规范 开发工具版本要求： IntelliJ IDEA：2018.3.5或以上版本。 Eclipse：3.6.0或以上版本。 Visual Studio：2019 version 16.8.4或以上版本。 开发语言环境版本要求： Java：1.8.111或以上版本的Java Development
service_id 是 String 服务ID。 最小长度：0 最大长度：20 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。
HL7服务器。 白名单 仅当“数据源方向”选择“源端”且“是否开启白名单”选择“是”时需要配置。 填写允许同步数据到源端HL7的服务器地址。 连接地址 仅当“数据源方向”选择“目标端”时需要配置。 填写HL7的访问IP地址和端口号。 IP地址获取方式：找到对应的源端为HL7的数据
批量删除Group 功能介绍 该接口用于批量删除Group。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI POST /v2/{project_id}/mqs/in
对API请求签名，指使用SASL的用户名与密码作为密钥对，将请求URL、消息头时间戳等内容进行签名，供后端服务进行校验。点此了解签名流程 使用Demo向指定Topic生产消息、消费消息和确认消息时，返回的响应消息结构请参考生产消息接口说明、消费消息接口说明和消费确认接口说明。 前提条件 本指南提供了Java语言的RESTful
lag Integer 剩余可消费消息数，即消息堆积数。 topic String Topic名称。 message_current_offset Integer 当前消费进度。 message_log_end_offset Integer 最大消息位置（LEO）。 请求示例 无 响应示例
附录：订阅的通知消息报文 以普通设备为例介绍订阅管理中MQS各报文示例。 消息属性 { "deviceIdentifier":"iottest2", // 设备标识 "eventTime":"1588843914884", // 消息时间 "gatewayIdentifier":"null"
PI占用1个连接。 消息集成：3个消息Topic占用1个连接。 设备集成：1000个设备占用1个连接。 实例名称 步骤2中配置的实例名称，此处支持修改。 Site实例描述 对购买的Site实例的描述信息。 消息集成（MQS）SASL_SSL 选择是否开启消息传输的SASL认证和S
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
