检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
如果晚于最晚的timestamp，则重置到最晚的timestamp。 message_offset、timestamp二者必选其一。 响应参数 无 请求示例 POST https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/group
使用ROMA Connect集成数据 概述 ROMA Connect支持接入多种类型的数据源，并通过数据集成任务实现源端到目标端的数据集成转换。ROMA Connect支持相同结构数据之间进行集成转换，也支持异构数据之间进行集成转换。 本章节通过完成一个API到MQS的数据集成配置样例，帮助您快速熟悉使用ROMA
更新时间 app_key String APP的key app_secret String 密钥 register_time String 注册时间 status Integer 状态 1： 有效 app_type String APP的类型： apig：存量apig应用，不推荐使用
ConsumeConcurrentlyStatus.CONSUME_SUCCESS; } }; //注册回调实现类来处理从RocketMQ拉取回来的消息 rocketMQConsumer.registerMessageList
key类型签名。 public_key_uri_prefix：获取public_key对应secret的uri前缀。具体uri格式为：https://{服务集成APIC 连接地址}{public_key_uri_prefix}{public_key签名密钥名称}。 app_route
查询子设备 功能介绍 查询子设备。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET /v2/{project_id}/link/instances/{inst
修改设备 功能介绍 修改设备信息。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI PUT /v2/{project_id}/link/instances/{inst
消息集成 消息集成流程介绍 创建Topic 配置Topic授权 连接Topic Kafka业务迁移 设备集成 设备集成流程介绍 创建产品 注册设备 接入MQTT协议设备 接入Modbus协议设备 接入OPC UA协议设备 配置数据转发规则 订阅设备通知 06 实践 通过提供多种场景的ROMA
客户端使用建议 Consumer使用建议 Consumer的owner线程需确保不会异常退出，避免客户端无法发起消费请求，阻塞消费。 确保处理完消息后再做消息commit，避免业务消息处理失败，无法重新拉取处理失败的消息。 Consumer不能频繁加入和退出group，频繁加入和
创建设备 功能介绍 创建设备。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI POST /v2/{project_id}/link/instances/{instance_id}/devices
API类型 1：公有API 2：私有API req_protocol String API的请求协议 HTTP HTTPS BOTH：同时支持HTTP和HTTPS 缺省值：HTTPS req_method String API的请求方式 req_uri String 请求地址。可以包含请
API类型 1：公有API 2：私有API req_protocol String API的请求协议 HTTP HTTPS BOTH：同时支持HTTP和HTTPS 缺省值：HTTPS req_method String API的请求方式 req_uri String 请求地址。可以包含请
描述 error_code String 错误码。 error_msg String 错误信息。 请求示例 查询消息偏移量。 GET https://{endpoint}/v2/{project_id}/mqs/instances/{instance_id}/messages?a
租户每个区域对应的项目ID。 instance_id string 是 租户使用ROMA Connect的实例ID。 请求消息 请求参数 无 请求示例 https://example.cloud.com/v1/80e2b******f4a398d6409a50932d917/link/instan
查询目标数据源列表 功能介绍 查询目标数据源列表。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET /v2/{project_id}/link/instanc
String 删除失败的消费组ID。 error_message String 删除失败的原因。 请求示例 批量删除消费组。 "POST https://{endpoint}/v2/{project_id}/mqs/instances/{instance_id}/groups/batch-delete"
"min_version" : "", "links" : { "rel" : "self", "href" : "https://roma.example.com/" }, "id" : "v2", "updated" : "2020-06-28T12:20:21Z"
业务使用介绍 功能简介 消息集成MQS是ROMA Connect的消息集成组件，使用统一的消息接入机制，提供跨网络访问的安全、标准化消息通道。使用ROMA Connect进行消息集成，有如下优势： 支持原生Kafka特性 兼容社区版Kafka的API，具备原生Kafka的所有消息处理特性。
租户每个区域对应的项目ID。 instance_id string 是 租户使用ROMA Connect的实例ID。 请求消息 请求参数 无 请求示例 https://example.cloud.com/v1/80e2b******f4a398d6409a50932d917/link/instan
String 微服务编号 instance_id String 实例编号 service_type String 微服务类型： CSE：CSE微服务注册中心 CCE：CCE云容器引擎（暂不支持） cse_info MicroServiceInfoCSE object CSE基础信息 cce_info
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
