检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
"support_features" : "kafka.crossvpc.domain.enable,route,kafka.new.pod.port,feature.physerver.kafka.topic.modify,feature.physerver.kafka.topic.accesspolicy
服务端才认为消费组客户端真正下线。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI PUT /v2/{engine}/{project_id}/mqs/instan
从OBS解析文件到RDS数据库,采集过一次后,后面采集会进行更新吗? 如果是采集同一个文件,每次在OBS上更新文件,目标端数据库有主键情况下,每次会根据主键更新数据。 如果是采集多个文件,目标端数据库有主键且主键相同的情况下,每次都会更新成时间最早的文件里的值,即数据内容没有变化
"enable_publicip" : true, "publicip_address" : "10.10.10.170", "ssl_enable" : true, "cross_vpc_info" : "{\"192.168.0.227\":{\"advertised_ip\":\"192
分组下存在API时分组无法删除,需要删除所有分组下的API后,再删除分组。 删除分组时,会一并删除直接或间接关联到该分组下的所有资源,包括独立域名、SSL证书等等。并会将外部域名与子域名的绑定关系进行解除(取决于域名cname方式)。 URI DELETE /v1/{project_id}/apic/instance
--broker-list IP:9094,IP:9095,IP:9096 --topic TopicName ROMA Connect实例已开启SASL_SSL时执行的命令: kafka-console-producer.bat --broker-list IP:9095,IP:9096,IP:9097
获取的域名地址。您也可以使用IP地址访问API, API调用场景 API请求参数配置 使用域名调用API ROMA Connect允许使用分组分配的子域名或分组绑定的域名调用API,无需另外配置。 使用IP调用DEFAULT分组的API ROMA Connect允许使用IP地址调
FDI各类数据库支持哪些数据类型? FDI各类数据库支持的数据类型有: Kafka数据库:string MySQL数据库:integer,bigint,number,varchar,char,float,date,timestamp,datetime Oracle数据库:inte
获取一个配置,用于访问MQS提供的Kafka(开启sasl_ssl)。 方法详情 public static KafkaConfig getConfig(String servers, String groupId) 访问MQS提供的kafka(不开启sasl_ssl)。 输入参数
UrlDomain 参数 参数类型 描述 id String 域名编号 domain String 访问域名 cname_status Integer 域名cname状态: 1:未解析 2:解析中 3:解析成功 4:解析失败 ssl_id String SSL证书编号 ssl_name
删除SSL证书 功能介绍 删除ssl证书接口,删除时只有没有关联域名的证书才能被删除 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI DELETE /v2/{proj
Connect实例,源端实例配置后目标端自动关联,无需配置。 目标端集成应用 选择MRS Kafka数据源所属的集成应用,在接入数据源时已配置。 目标端数据类型 选择“MRS Kafka”。 数据源名称 选择接入数据源中已配置的MRS Kafka数据源。 Topic名称 填写用户在MRS Kafka服务已创建的Topic名称,不可随意自定义。
消息大小:不能超过10MB 使用SASL_SSL协议访问ROMA Connect:确保DNS具有反向解析能力,或者在hosts文件配置ROMA Connect所有节点ip和主机名映射,避免Kafka client做反向解析,阻塞连接建立。 磁盘容量申请超过业务量 * 副本数的2倍,即保留磁盘空闲50%左右。
其中映射模式包含自动配置和手动配置两种方式。 源端与目标端字段名请勿使用对应数据库的关键字,否则可能导致任务运行异常。 映射模式 自动配置Mapping 若源端信息与目标端信息中都定义了元数据,可使用“自动Mapping”方式配置Mapping信息。 单击“自动Mapping”,
X版本的Python。 Go:1.14及以上版本的Go。 C#:6.0及以上版本的.NET。 客户端版本使用建议: ROMA Connect的Kafka版本 Kafka客户端建议版本 1.1.0 Java:1.1.0及以上版本 Python:2.0.1及以上版本 Go:1.8.2及以上版本 C#:1
CipherUtils类说明 路径 com.huawei.livedata.lambdaservice.security.CipherUtils 说明 解密密码箱中密码的key值。 在获取解密密码箱中普通密码的key值时,注意敏感信息保护,避免敏感信息泄露。 方法列表 返回类型 方法和说明
消息集成 向Topic生产的消息是否有长度限制? MQS支持的Kafka服务端版本是多少?
到下述配置中。其中参数kafka.rest.group为消费组ID,可在客户端指定。 # Kafka rest endpoint. kafka.rest.endpoint=https://{MQS_Instance_IP_Addr}:9292 # Kafka topic name
转发规则的目的端,把设备上报的数据转发到DIS。 分布式消息服务 Kafka 分布式消息服务 Kafka(Distributed Message Service for Kafka,简称Kafka)是一款基于开源社区版Kafka提供的消息队列服务,是一个拥有高吞吐、可持久化、可水
objects 分组上绑定的独立域名列表 表7 UrlDomain 参数 参数类型 描述 id String 域名编号 domain String 访问域名 cname_status Integer 域名cname状态: 1:未解析 2:解析中 3:解析成功 4:解析失败 ssl_id String