检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
部分HTTP通用响应头不支持返回，如Location等。 使用示例 com.roma.apic.livedata.client.v1.HttpClient importClass(com.roma.apic.livedata.client.v1.HttpClient); importClass(com.roma.apic
0时填写，不填写默认为client_id。 缺省值：client_id 最小长度：0 最大长度：256 client_secret String 访问API服务的客户端密钥。 认证方式为oauth2.0时填写。 最小长度：0 最大长度：256 client_secret_key String
数据源 数据源连接测试失败排查操作 MRS Hive数据源测试连接失败 FTP数据源测试连接失败 OBS数据源测试连接失败 Kafka数据源连接失败
"vpc_client_plain" : false, "support_features" : "kafka.crossvpc.domain.enable,route,kafka.new.pod.port,feature.physerver.kafka.topic.modify
0时填写，不填写默认为client_id。 缺省值：client_id 最小长度：0 最大长度：256 client_secret 否 String 访问API服务的客户端密钥。 认证方式为oauth2.0时填写。 最小长度：0 最大长度：256 client_secret_key
设备消息并发量 2500TPS 消息集成规格在以下条件中测试得出： 连接方式：内网连接 认证方式：SASL_SSL 数据大小：1KB/10KB 磁盘类型：超高I/O SSD 设备集成规格在以下条件中测试得出： 上行消息 连接方式：内网连接 消息大小：512byte 消息目的端：MQS Topic
0时填写，不填写默认为client_id。 缺省值：client_id 最小长度：0 最大长度：256 client_secret String 访问API服务的客户端密钥。 认证方式为oauth2.0时填写。 最小长度：0 最大长度：256 client_secret_key String
获取一个配置，用于访问MQS提供的Kafka（开启sasl_ssl）。 方法详情 public static KafkaConfig getConfig(String servers, String groupId) 访问MQS提供的kafka（不开启sasl_ssl）。 输入参数
ble" : true, "vpc_client_plain" : false, "support_features" : "kafka.crossvpc.domain.enable,feature.physerver.kafka.topic.accesspolicy,rabbitmq
FDI各类数据库支持哪些数据类型？ FDI各类数据库支持的数据类型有： Kafka数据库：string MySQL数据库：integer，bigint，number，varchar，char，float，date，timestamp，datetime Oracle数据库：inte
首先需要将MRS的IP全部绑定EIP，然后在MRS配置文件中的私网IP全部替换成EIP，再到hdfs-site.xml文件中添加一个配置项“dfs.client.use.datanode.hostname”，值设为“true”。 父主题： 数据集成普通任务
0时填写，不填写默认为client_id。 缺省值：client_id 最小长度：0 最大长度：256 client_secret 否 String 访问API服务的客户端密钥。 认证方式为oauth2.0时填写。 最小长度：0 最大长度：256 client_secret_key
try { final MqttClient client = new MqttClient(host, clientId); client.connect(mqttConnectOptions);
Connect所有节点ip和主机名映射，避免Kafka client做反向解析，阻塞连接建立。 磁盘容量申请超过业务量 * 副本数的2倍，即保留磁盘空闲50%左右。 业务进程JVM内存使用确保无频繁FGC，否则会阻塞消息的生产和消费。 建议在Kafka客户端侧配置日志转储，否则容易引起磁盘被日志打满的情况。
RabbitMqProducer类说明 路径 com.roma.apic.livedata.client.v1.RabbitMqProducer 说明 生产RabbitMQ消息。若发送消息没有异常，则消息发送成功；若发送消息抛出异常，则消息发送失败。 使用示例 用direct交换
发布连接器 概述 在ROMA Connect中创建连接器后，您需要发布一个连接器实例，实现ROMA Connect与已部署连接器的对接。ROMA Connect通过已发布的连接器实例接入自定义数据源，实现对数据源的读写。 前提条件 已完成连接器的线下开发和部署，连接器与ROMA
志消息，识别出告警日志并发送告警消息/邮件。 分区 Kafka将消息主题（Topic）划分为多个分区（Partition），消息被分布式存储在不同分区中，实现Kafka的水平扩展与高可用。 副本 为了提高消息的可靠性，Kafka的每个分区会有多个副本，对消息进行冗余备份。分区在每
接入HANA数据源 定时 定时，实时 定时 定时 接入LDAP数据源 定时 - - - 接入IBM MQ数据源 实时 定时，实时 - - 接入Kafka数据源 实时 定时，实时 - 实时 接入MySQL数据源 定时 定时，实时 定时，实时 定时，实时 接入MongoDB数据源 定时 定时，实时
连接器 创建连接器 发布连接器 父主题： 数据集成指导
创建连接器 概述 ROMA Connect提供了常见的数据源连接支持，如关系型数据库、消息队列、API、NoSQL、对象存储等，这些数据源可以直接在ROMA Connect中使用，您只需要接入数据源，创建并启动数据集成任务，就可以将您的源端数据集成到目标端。 如果ROMA Con
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
