-
分布式消息服务Kafka版 - 分布式消息服务Kafka版
支持区域: 全部 删除消费组 重置消费进度 查看消费者连接地址 修改配置参数 分布式消息服务Kafka版为实例、Topic、消费者提供了几个常用配置参数的默认值,您可以根据实际业务需求,在控制台自行修改参数值。 支持区域: 全部 如何修改配置参数? 标签 标签是Kafka实例
-
计费样例 - 分布式消息服务Kafka版
/包月计费,购买时长为1个月。那么在3~4月份,该Kafka实例总共产生多少费用呢? 计费构成分析 可以将Kafka实例的使用阶段按照计费模式分为两段:在2023/03/18 15:30:00 ~ 2023/03/20 10:30:00期间为按需计费,2023/03/20 10:30:00
-
使用DNAT实现公网访问Kafka - 分布式消息服务Kafka版
网关。 图2 购买公网NAT网关 单击“立即购买”,进入规格确认页面。 确认规格无误后,如果“计费模式”选择“包年/包月”,单击“去支付”。根据界面提示信息,支付费用。如果“计费模式”选择“按需付费”,单击“提交”。 步骤三:添加DNAT规则 在“公网NAT网关”页面,在新购买的
-
如何选择Kafka实例的存储空间? - 分布式消息服务Kafka版
预留磁盘大小100GB。Kafka集群中,每个Kafka节点会使用33GB的磁盘作为日志和Zookeeper数据的存储,因而实际可用存储会小于购买存储。 其中,副本数在创建Topic时可以选择,默认为3副本存储。如果开启了Kafka自动创建Topic功能,自动创建的Topic默认为3副本,副本数可以通过“配置参数”页签中的“default
-
查询指定实例 - 分布式消息服务Kafka版
2:Kafka实例的基准带宽为1200MByte/秒。 type String 实例类型:集群,cluster charging_mode Integer 付费模式,1表示按需计费,0表示包年/包月计费。 vpc_id String VPC ID。 vpc_name String VPC的名称。 created_at
-
查看Kafka消费组信息 - 分布式消息服务Kafka版
SASL_PLAINTEXT:如果已经设置了用户名和密码,请跳过此步骤。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件,参考3增加用户名和密码。 SASL_SSL:如果已经设置了用户名和密码,以及SSL证书配置,请跳过
-
查询所有实例列表 - 分布式消息服务Kafka版
kafka.cluster.c3.high.2:Kafka实例的基准带宽为1200MB。 charging_mode Integer 付费模式,1表示按需计费,0表示包年/包月计费。 vpc_id String VPC ID。 vpc_name String VPC的名称。 created_at
-
查询所有实例列表 - 分布式消息服务Kafka版
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak := os.Getenv("CLOUD_SDK_AK") sk := os.Getenv("CLOUD_SDK_SK")
-
查询Smart Connector任务详情 - 分布式消息服务Kafka版
示) target_db Integer 目标数据库,默认为-1。(仅目标端类型为Redis时会显示) consumer_strategy String 转储启动偏移量,latest为获取最新的数据,earliest为获取最早的数据。(仅目标端类型为OBS时会显示) destination_file_type
-
配置Kafka间的数据复制 - 分布式消息服务Kafka版
如果对端实例中设置了“default.replication.factor”,此参数的优先级高于“default.replication.factor”。 启动偏移量 支持两种偏移量: 最早:最小偏移量,即获取最早的数据。 最新:最大偏移量,即获取最新的数据。 压缩算法 复制消息所使用的压缩算法。
-
错误码 - 分布式消息服务Kafka版
has the read-only permission and cannot perform operations on DMS. 租户只有只读权限,无法操作DMS。 请检查租户权限 403 DMS.00403003 This role does not have the permissions
-
修改实例信息 - 分布式消息服务Kafka版
security_group_id String 否 安全组ID。 retention_policy String 否 容量阈值策略。 支持两种策略模式: produce_reject: 生产受限 time_base: 自动删除 enterprise_project_id String 否
-
Kafka Manager概述 - 分布式消息服务Kafka版
创建一台与Kafka实例相同VPC和相同安全组的Windows服务器,详细步骤请参考购买并登录Windows弹性云服务器。 如果是已经开启了公网访问,该步骤为可选,在本地浏览器中即可访问,不需要单独的Windows弹性云服务器。 在实例详情信息页面,获取Kafka Manager地址。
-
Logstash对接Kafka生产消费消息 - 分布式消息服务Kafka版
图2 Kafka实例作为Logstash输出源 Logstash从数据库采集数据,然后发送到Kafka实例中进行存储。Kafka实例作为Logstash输出源时,由于Kafka的高吞吐量,可以存储大量数据。 约束与限制 Logstash从7.5版本开始支持Kafka Integration
-
配置Kafka流控 - 分布式消息服务Kafka版
表示流控创建成功。 进入“流控管理 > 流控列表”页面,在“User/Client”页签中,单击页面左上角的“仅设置了用户名”/“仅设置了客户端ID”/“设置了用户名和客户端ID”,输入新创建的流控名称,按“Enter”,查看新创建的流控。 图1 查看新创建的流控 创建Topic流控
-
创建实例 - 分布式消息服务Kafka版
vpc_client_plain 否 Boolean VPC内网明文访问。 bss_param 否 BssParam object 表示包周期计费模式的相关参数。 如果为空,则默认计费模式为按需计费;否则是包周期方式。 表3 TagEntity 参数 是否必选 参数类型 描述 key 否 String 标签键。
-
构造请求 - 分布式消息服务Kafka版
} } 到这里为止这个请求需要的内容就具备齐全了,您可以使用curl、Postman或直接编写代码等方式发送请求调用API。对于获取用户Token接口,返回的响应消息头中“x-subject-token”就是需要获取的用户Token。有了Token之后,您就可以使用Token认证调用其他API。
-
Kafka相关概念 - 分布式消息服务Kafka版
r副本复制到其他副本(Follower)。 Kafka的主题和分区属于逻辑概念,副本与代理属于物理概念。下图通过消息的生产与消费流向,解释了Kafka的分区、代理与主题间的关系。 图1 Kafka消息流 老化时间 消息的最长保留时间,消费者必须在此时间结束前消费消息,否则消息将被删除。删除的消息,无法被消费。
-
创建Smart Connect任务 - 分布式消息服务Kafka版
environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment ak := os.Getenv("CLOUD_SDK_AK") sk := os.Getenv("CLOUD_SDK_SK")
-
续费概述 - 分布式消息服务Kafka版
到期后仍未续费,资源状态变为“已冻结”。 超过宽限期仍未续费将进入保留期,如果保留期内仍未续费,资源将被自动删除。 华为云根据客户等级定义了不同客户的宽限期和保留期时长。 在Kafka实例到期前均可开通自动续费,到期前7日凌晨3:00首次尝试自动续费,如果扣款失败,每天凌晨3:0