检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
描述 config_type 是 String 应用配置类型： variable：模板变量 password：密码 certificate：证书 config_value 否 String 应用配置值： config_type = variable：config_value为模板变量的值
该参数仅在编辑FDI任务时可配置。 选择是否开启重置迁移时间初始值。 开启：开启后，增量迁移时每次调度时开始的时间为时间戳初始值配置的时间。 关闭：关闭时，增量迁移时每次调度的开始时间为上一次调度的结束时间。 时间补偿(毫秒) 仅当“是否增量迁移”选择开启时需要配置。 为了避免源端生成数据时存在滞后，导致ROMA
传入该参数。 password string 否 MQS启用SSL时，需要传入MQS的密码，未启用SSL不需要传入该参数。 请求示例 https://example.cloud.com/v1/80e2b******f4a398d6409a50932d917/link/instan
重启生产客户端，将生产业务迁移到ROMA Connect实例中。 生产业务迁移后，观察连接ROMA Connect实例的消费业务是否正常。 等待原Kafka中数据消费完毕，关闭原有消费业务客户端。 迁移结束。 迁移持久化数据 如果需要将原Kafka的已消费数据也迁移到ROMA Connect实例，可以使用开源工具
protocol 是 String 使用以下协议，对VPC中主机执行健康检查： TCP HTTP HTTPS path 否 String 健康检查时的目标路径。protocol = http或https时必选 method 否 String 健康检查时的请求方法 缺省值：GET port 否
导出数据失败 检查是否存在数据 400 RML.0012 Failed to download ssl certificate. 下载SSL证书失败 检查网络连接是否正常 400 RML.0013 The input parameter oid is null. 输入的唯一标识不能为空
Kafka日志推送插件说明 概述 ROMA Connect支持收集服务集成下已开放API的调用日志信息。Kafka日志推送插件提供了把API的详细调用日志推送到Kafka的能力，方便用户获取API的调用日志信息。 使用限制 同一个API在同一个环境中只能绑定一个相同类型的插件策略，已被API绑定的插件策略无法删除。
Verify(r, m.group(3)): return 'Verify authroization failed.', 401 运行服务器，验证代码正确性。下面示例使用JavaScript SDK中的html签名工具生成签名。 填入如图所示字段后，单击“Send request”，
groups[3].Value)) { context.Result = new UnauthorizedResult(); } 运行服务器，验证代码正确性。下面示例使用JavaScript SDK中的html签名工具生成签名。 填入如图所示字段后，单击“Send request”，
ActiveMQ ActiveMQ是一种基于Java Message Service（JMS）标准的开源消息中间件，提供可靠、高效、可扩展的消息传递机制，支持多种消息协议和传输协议，如TCP、UDP、SSL、NIO等。ActiveMQ支持多种队列和主题模式，可以用于异步消息传递、
ActiveMQ ActiveMQ是一种基于Java Message Service（JMS）标准的开源消息中间件，提供可靠、高效、可扩展的消息传递机制，支持多种消息协议和传输协议，如TCP、UDP、SSL、NIO等。ActiveMQ支持多种队列和主题模式，可以用于异步消息传递、
C#客户端使用说明 操作场景 本文介绍C#版本的Kafka客户端连接指导，包括Kafka客户端安装，以及生产、消费消息。 前提条件 已获取MQS连接信息，具体请参见开发准备。 已安装开发工具和C#开发语言环境，具体请参见开发准备。 引入Kafka客户端 MQS基于Kafka社区版本1
启停状态 选择是否启用服务器，只有启用后，请求才会分发到该服务器上。 配置健康检查配置。 健康检查配置默认打开，若不需要执行健康检查，可关闭健康检查配置。 表5 健康检查配置 参数 说明 协议 选择健康检查所使用的协议，可选择“TCP”、“HTTP”和“HTTPS”。 双向认证
配置Kafka日志推送策略 ROMA Connect支持通过插件策略的方式，为API提供灵活的扩展能力。Kafka日志推送策略提供了把API的详细调用日志推送到Kafka的能力，方便用户获取API的调用日志信息。 插件策略和API本身相互独立，只有为API绑定插件策略后，插件策略
配置Topic授权（可选） 概述 仅当ROMA Connect实例开启了MQS的SASL_SSL时，需要配置Topic的连接授权，把消息收发权限授权给集成应用。客户端向Topic发布和订阅消息时，需要使用授权集成应用的Key和Secret进行安全认证。 Topic所属的集成应用默
protocol String 使用以下协议，对VPC中主机执行健康检查： TCP HTTP HTTPS path String 健康检查时的目标路径。protocol = http或https时必选 method String 健康检查时的请求方法 缺省值：GET port Integer
hmac(string value, string secret, string algorithm) 使用提供的值、密钥和散列函数算法生成基于散列的消息验证码。必须是HmacSHA1、HmacSHA256或HmacSHA512中的一种。 encrypt(string value, string
Java客户端使用说明 操作场景 本文介绍Java版本的Kafka客户端连接指导，并完成客户端连接以及消息生产与消费的相关示例。 前提条件 已获取MQS连接信息，具体请参见开发准备。 已安装开发工具和Java开发语言环境，具体请参见开发准备。 引入Kafka客户端 MQS基于Kafka社区版本1
为什么规则引擎的数据目的端未收到设备发送的消息？ 数据目的端未收到设备发送的消息主要有以下原因： 可能是您的安全组没有添加正确的入方向规则。 请您进入“实例信息”界面，找到您的安全组。单击安全组名称进入安全组详情页面，然后根据表1添加相应的入方向规则。 表1 安全组参数 参数 端口
Go客户端使用说明 操作场景 本文以Linux CentOS环境为例，介绍Go版本的Kafka客户端连接指导，包括Kafka客户端安装，以及生产、消费消息。 前提条件 已获取MQS连接信息，具体请参见开发准备。 已安装开发工具和Python开发语言环境，具体请参见开发准备。 引入Kafka客户端
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
