消息发送的实时性。 图2 消息逐条生产与消费 此外，批量消费消息时，消费者应按照接收的顺序对消息进行处理、确认，当对某一条消息处理失败时，不再需要继续处理本批消息中的后续消息，直接对已正确处理的消息进行确认即可。 巧用消费组协助运维 用户使用ROMA Connect作为消息管理系

查看更多 →

在左侧的导航栏选择“消息集成 MQS > 消息查询”，进入消息查询页面。 在页面右上角选择要查询消息的Topic，界面自动展示该Topic中存储的消息记录。 您也可以单击“高级搜索”，设置查询条件，然后单击“搜索”，查询消息。 查询方式：选择消息的查询方式。 按生产时间查询：按生产消息的时间查询。

查看更多 →

进入ROMA Connect主界面，单击右上角“购买ROMA Connect实例”，尝试购买ROMA Connect实例，如果无法购买ROMA Connect实例（假设当前权限仅包含ROMA ReadOnlyAccess），表示“ROMA ReadOnlyAccess”已生效。 在“服务列表”中选择除ROMA

查看更多 →

ROMA运维与管理服务 产品介绍 常见问题 计费说明 父主题： 运维与管理

查看更多 →

您可以在集成应用列表中，单击集成应用左侧的“”，查看该集成应用已授予权限的IAM用户以及授予的权限范围。 使用3中被授权的IAM用户登录ROMA Connect控制台并进入对应的ROMA Connect实例，查看该用户是否具备该集成应用资源的相关管理权限。 父主题： 集成应用管理

查看更多 →

数据源管理 ROMA Connect支持的数据源 接入API数据源 接入ActiveMQ数据源 接入ArtemisMQ数据源 接入DB2数据源 接入DIS数据源 接入DWS数据源 接入DM数据源 接入Gauss100数据源 接入FTP数据源 接入HL7数据源 接入HANA数据源 接入HIVE数据源

查看更多 →

500 MQS.00500006 Internal service error. 内部服务错误。 请联系技术支持。 500 MQS.00500017 Internal service error. 内部服务错误。 请联系技术支持。 500 MQS.00500020 Internal

查看更多 →

访问WEBSOCKET服务的认证方式。 none basicauth 最小长度：0 最大长度：256 api_auth_detail ApiAuthDetail object API鉴权详细字段。 broker String KAFKA、MQS、ACTIVEMQ的 服务器 地址，多个IP:PORT，使用","分隔。 最小长度：0

查看更多 →

访问WEBSOCKET服务的认证方式。 none basicauth 最小长度：0 最大长度：256 api_auth_detail 否 ApiAuthDetail object API鉴权详细字段。 broker 否 String KAFKA、MQS、ACTIVEMQ的服务器地址，多个IP:PORT，使用","分隔。

查看更多 →

对接ROMA Connect调用服务的API 应用与数据集成平台（ROMA Connect）是一个全栈式的服务平台，聚焦应用和数据连接，提供数据、API、消息和设备集成能力，帮助企业快速联接云上云下，消除数字鸿沟，实现数字化转型。在AstroZero中，通过连接器和ROMA Connect对接后，可调用ROMA

查看更多 →

建议使用 云数据迁移 CDM。 表1 接入数据源 数据源接入配置 普通任务支持的集成模式（源端） 普通任务支持的集成模式（目标端） 组合任务支持的集成模式（源端） 组合任务支持的集成模式（目标端） 接入API数据源 定时 定时，实时 - - 接入ActiveMQ数据源 实时 定时，实时

查看更多 →

数据集成。 服务集成：把API、数据源和自定义函数封装成标准的RESTFul API，并对外开放。 消息集成：创建消息Topic，不同系统通过Topic进行对接，发送和接收消息。 设备集成：在云端定义设备模型和注册设备，设备通过集成SDK接入云端，发送和接收消息。 发布区域：华北

查看更多 →

30条 2 1 服务集成(API管理) API转发 1000TPS 2 1 托管API数量 100个 服务集成(数据API/函数API) 数据API/函数API转发 100TPS 2 1 自定义后端数量 50个 API流量 0.24Mbps 数据集成 非消息类数据流量 约2MBps，单任务最大4MBps

查看更多 →

pool initialization）。若API使用了自定义认证，可能会偶现自定义认证失败（错误信息为：Internal server error: xxx auth failed）。如果客户端有重连机制，则重连时可以恢复正常。 ROMA Site实例规格变更过程中，如果客户端调

查看更多 →

创建ROMA Site协同版实例 准备资源 创建实例 父主题： 实例管理

查看更多 →

"roma:tasks:create", "roma:tasks:operate", "roma:tasks:list", "roma:tasks:get"

查看更多 →

"bootstrap.servers": brokers, } producer, err := kafka.NewProducer(config) if err != nil { log.Panicf("producer error, err: %v", err) return

查看更多 →

Connect平台上发布并授权的API直接同步到平台。 同步后，在“API接口”页签中，可查看到“获取人员信息”API。 图6 获取人员信息API 单击API名称，可查看API具体信息，包括基本信息、消息头入参、输入和输出参数。 如果ROMA Connect平台上该API有更新，请在ROMA Connec

查看更多 →

从Roma同步连接器 您可以使用Roma Connect，创建组合应用并在Roma实例上启动后，通过API的方式对外暴露。通过圆桌同步功能将Roma Connect的能力引入圆桌并使用（推荐使用读取数据库的能力）。 从Roma同步连接器 登录圆桌，在页面右上角单击“轻应用构建”，进入“轻应用构建”平台。

查看更多 →

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

查看更多 →

修改后参数编码格式： default-storage-engine = INNODB character-set-server = utf8 collation-server=utf8_general_ci 父主题： 安装应用包失败

查看更多 →