MQS连接开发（RESTful API） Java Demo使用说明 生产消息接口说明 消费消息接口说明 消费确认接口说明 父主题： 消息集成开发指导

查看更多 →

将MQS中日志导入DWS 配置数据源 准备DWS表 配置FDI任务 父主题： 场景五：数据需求方数据服务计量

查看更多 →

Connect上分了主账号和子账号，在ROMA Exchange上不分主账号和子账号，主账号和子账号在ROMA Exchange上看到的两个账号。 用户在ROMA Connect上创建这些资产和在ROMA Exchange上发布资产时，使用的不是同一账号。 处理步骤 用户可以用资产发布时的账号访问ROMA Co

查看更多 →

Connect主要包含四个组件：数据集成（FDI）、服务集成（APIC）、消息集成（MQS）、设备集成（LINK）。 FDI 快速数据集成FDI（Fast Data Integration，简称FDI）是ROMA Connect的数据集成组件。FDI支持多种数据源（文本、消息、API、关系型数据和非关系

查看更多 →

已在本地PC上下载并安装接口调试工具。 步骤一：购买实例 选择实例类型。 登录ROMA API控制台，单击，选择区域。 在左侧导航栏选择“管理中心 > 实例管理”。 单击“购买实例”。 选择实例类型，以ROMA实例为例。 购买ROMA实例。 创建ROMA实例。 图2 配置实例信息 表1 配置实例信息 参数

查看更多 →

getSaslConfig(String servers, String groupId, String username, String password) 访问MQS提供的kafka（开启sasl_ssl）。 输入参数 servers：kafkaConfig中的bootstrap.servers信息 gro

查看更多 →

配置ROMA Exchange实例 进入租户管理员配置界面 配置OBS存储功能 短信的配置 邮件的配置 搜索服务配置 产品初始化配置 产品高级能力配置 门户页面页签名称配置 评价敏感词及敏感词处理方式管理 根据业务需要配置其它系统参数

查看更多 →

选择“产品”，在菜单栏中选择“企业应用 > 应用平台”，单击“ROMA 资产中心 ROMAExchange”，进入ROMA Exchange官网页。 申请购买ROMA Exchange。 用户申请购买后，系统会为用户部署一套ROMA Exchange实例，该套实例包括ROMA Exchange资产中心和运营管理平台。

查看更多 →

丰富的API安全、运维能力。 API测试 通过导入API生成测试用例，快速实现API测试的覆盖。 API消费 ROMA API提供内部市场的能力，将API包装成API产品，支持上架到API目录中，提供完整的API文档展示能力，以及订阅功能。 API分析 提供可视化的API指标数据，方便API管理者进行维护和运营。

查看更多 →

ROMA数据集成 应用与数据集成平台（ROMA Connect）是一个全栈式的服务平台。ROMA数据集成连接器包含“ 创建调度计划”和“手工触发单个任务”等执行动作。 连接参数 ROMA数据集成连接器使用IAM认证，连接参数说明如表1所示。 表1 连接参数说明 名称 必填 说明 示例值/默认值

查看更多 →

在数据接入编辑页面右侧，选择“消息跟踪”页签，单击“启动”，可启动消息跟踪。消息跟踪在一个周期（默认30分钟）后，自动关闭。 图15 启动消息跟踪 启动消息跟踪后，可实时查看上报的报文处理情况。 图16 消息跟踪 异常处理 当数据源类型选择的是ROMA时，配置完数据接入后，MQS平台收不到消息，业务设

查看更多 →

c发布和订阅消息的权限。 操作步骤 登录ROMA Connect控制台，在“实例”页面单击实例上的“查看控制台”，进入实例控制台。 在左侧的导航栏选择“消息集成 MQS > Topic管理”，单击Topic右侧的“设置集成应用权限”。 在设置集成应用权限弹窗中，为集成应用配置授权。

查看更多 →

Request { "error_code" : "SCB.00000000", "error_msg" : "Parameter is not valid for operation [romalink.link-ruledest.query]. Parameter is [rule_oid]

查看更多 →

配置数据集参数。 图2 ROMA连接器配置示例 API接口：API请求路径。 请求类型：请求的类型，如GET、POST。 参数：输入参数，请根据实际请求进行配置。 测试API接口：用于测试该接口，单击“测试API接口”，“样例报文”中会显示输出结果。 样例报文：对应API接口的响应样例报

查看更多 →

2019/07/31 新增推送数据至ROMA Connect的能力 ROMA Connect是一个全栈式的企业集成平台，源自华为数字化转型集成实践，聚焦应用和数据连接，适配多种企业常见的使用场景。 IoT平台将数据推送至ROMA Connect的MQS服务，应用 服务器 可基于MQS获取设备上报消息。

查看更多 →

/v1/topic/{topic_name}/messages 表1 参数说明 参数 类型 必选 说明 topic_name String 是 主题名称。 请求消息 请求参数 参数 类型 必选 说明 messages Array 是 消息列表，数组大小不能超过10，且不能为空数组。 表2 messages参数 参数

查看更多 →

nsumer频繁做rebalance，阻塞消费。 Consumer数量不能超过Topic分区数，否则会有Consumer拉取不到消息。 Consumer需周期poll，维持和server的心跳，避免心跳超时，导致Consumer频繁加入和退出，阻塞消费。 Consumer拉取的消

查看更多 →

创建日志消息队列所属的集成应用 概述 ROMA Connect通过集成应用来实现同一实例内不同用户间的资源隔离。用户在ROMA Connect实例中创建的资源（如数据源、API、Topic、产品等）都要有归属的集成应用，非管理员权限的用户默认只能查看和管理自己创建的集成应用和资源

查看更多 →

AstroZero支持接入哪些类型的数据？ AstroZero的数据连接可以分为以下几类： 消息类的数据 通过AstroZero提供的数据接入能力，从外部数据源（如ROMA的MQS、Kafka、 设备接入IoTDA 等）获取数据，详情请参见如何配置数据接入。 接口类的数据 通过Ast

查看更多 →

将API计量信息推送至MQS 创建日志消息队列所属的集成应用 创建MQS Topic 创建Kafka日志推送插件 插件绑定API 父主题： 场景五：数据需求方数据服务计量

查看更多 →

打造数据底座，提供标准数据服务 将所有的数据，使用ROMA FDI与MQS组件进行快速集成，并开放给企业不同后端的服务。比如闸机设备系统的车辆数据，资产管理系统的设备状态、路灯系统的开关与设备信息等等，数据以实时或者异步批量的方式传输给后端服务，用作分析与联动管理。 同时，ROMA Connect的高度可

查看更多 →