-
查询分区指定时间段的消息 - 分布式消息服务Kafka版
查询分区指定时间段的消息 功能介绍 查询分区指定时间段的消息。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/management/topics/{topic}/messages 表1 路径参数
-
查看和重置Kafka消费进度 - 分布式消息服务Kafka版
停止消费,然后重置消费进度。 停止待重置消费进度的消费者客户端后,需要等待一段时间(即ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间,默认为1000毫秒),服务端才会认为此消费者已下线。 查看消费进度(控制台) 登录管理控制台。 在管理控制台左上角单击,选择区域。
-
Go - 分布式消息服务Kafka版
"log" "os" "os/signal" "syscall" ) var ( brokers = "ip1:port1,ip2:port2,ip3:port3" topics = "topic_name" user = "username" password
-
查询所有实例列表 - 分布式消息服务Kafka版
不能为空。 对于同一个实例,Key值唯一。 长度为1~128个字符(中文也可以输入128个字符)。 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @ 首尾字符不能为空格。 value String 标签值。 长度为0~255个字符(中文也可以输入255个字符)。
-
查询产品规格列表 - 分布式消息服务Kafka版
是创建上述Kafka实例时需要配置的产品ID。 同时,unavailable_zones字段表示资源不足的可用区列表,如果为空,则表示所有可用区都有资源,如果不为空,则表示字段值的可用区没有资源。所以必须确保您购买的资源所在的可用区有资源,不在该字段列表内。 当前页面API为历史
-
重置消费组消费进度到指定位置 - 分布式消息服务Kafka版
待重置消费组客户端,然后等待一段时间(即ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间,默认为1000毫秒)后,服务端才认为此消费组客户端已下线。 调用方法 请参见如何调用API。 URI PUT /v2/kafka/{project_
-
购买Kafka实例 - 分布式消息服务Kafka版
x版本不支持规格测算。 图2 规格测算 选择单机版时,您可以创建一个2.7版本、单代理的实例。 版本:Kafka的版本号,仅支持2.7。 CPU架构:支持“x86计算”,保持默认值即可。 在“代理规格”中,请根据业务需求选择相应的代理规格。 代理数量:只支持1个代理。 在“单个代理存
-
查询单个转储任务 - 分布式消息服务Kafka版
huaweicloud.sdk.kafka.v2.region.KafkaRegion; import com.huaweicloud.sdk.kafka.v2.*; import com.huaweicloud.sdk.kafka.v2.model.*; public class
-
约束与限制 - 分布式消息服务Kafka版
用户约束与限制 限制项 约束与限制 创建用户的数量 2023年7月15日前创建的Kafka实例,一个实例最多创建20个用户。2023年7月15日及以后创建的Kafka实例,一个实例最多创建500个用户。 代理故障场景 实例中部分代理故障时,无法创建、修改和删除用户,以及重置密码,只能查询用户。
-
查询分区最早消息的位置 - 分布式消息服务Kafka版
huaweicloud.sdk.kafka.v2.region.KafkaRegion; import com.huaweicloud.sdk.kafka.v2.*; import com.huaweicloud.sdk.kafka.v2.model.*; public class
-
查询Kafka实例的协调器信息 - 分布式消息服务Kafka版
查询Kafka实例的协调器信息 功能介绍 查询Kafka实例的协调器信息。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/management/coordinators 表1 路径参数 参数 是否必选
-
Kafka实例查询Topic - 分布式消息服务Kafka版
huaweicloud.sdk.kafka.v2.region.KafkaRegion; import com.huaweicloud.sdk.kafka.v2.*; import com.huaweicloud.sdk.kafka.v2.model.*; public class
-
实例扩容 - 分布式消息服务Kafka版
huaweicloud.sdk.kafka.v2.region.KafkaRegion; import com.huaweicloud.sdk.kafka.v2.*; import com.huaweicloud.sdk.kafka.v2.model.*; public class
-
业务过载处理建议 - 分布式消息服务Kafka版
常用的压缩算法包括:ZIP,GZIP,SNAPPY,LZ4等。选择压缩算法时,需考虑数据的压缩率和压缩耗时。通常压缩率越高的算法,压缩耗时也越高。对于性能要求高的系统,可以选择压缩速度快的算法,比如LZ4;对于需要更高压缩比的系统,可以选择压缩率高的算法,比如GZIP。 可以在生产者端配置“compression
-
修改实例信息 - 分布式消息服务Kafka版
huaweicloud.sdk.kafka.v2.region.KafkaRegion; import com.huaweicloud.sdk.kafka.v2.*; import com.huaweicloud.sdk.kafka.v2.model.*; public class
-
创建实例 - 分布式消息服务Kafka版
当您选择开启,表示生产或消费一个未创建的Topic时,会自动创建一个包含3个分区和3个副本的Topic。 默认是false关闭。 storage_spec_code 是 String 存储IO规格。 取值范围: dms.physical.storage.high.v2:使用高IO的磁盘类型。
-
连接问题 - 分布式消息服务Kafka版
开启公网访问后,在哪查看公网IP地址? Kafka支持服务端认证客户端吗? 连接开启SASL_SSL的Kafka实例时,ssl truststore文件可以用PEM格式的吗? 下载的证书JKS和CRT有什么区别? Kafka支持哪个版本的TLS? Kafka实例连接数有限制吗? 客户端单IP连接的个数为多少?
-
为什么限制Topic的总分区数? - 分布式消息服务Kafka版
300GB~1500000GB 750 表2 Kafka实例规格(单机版实例) 实例规格 代理个数 单个代理TPS 单个代理分区上限 单个代理建议消费组数 单个代理客户端总连接数上限 存储空间范围 单个代理流量规格(MB/s) kafka.2u4g.single.small 1 20000
-
测试Kafka实例TPS - 分布式消息服务Kafka版
高I/O kafka-15 3 kafka.16u32g.cluster 否 高I/O 购买实例后,创建如表2所示Topic,创建步骤请参考创建Kafka Topic。 表2 Topic参数 名称 是否同步复制 是否同步落盘 副本数 分区数 topic-01 否 否 3 30 topic-02
-
Kafka实例创建Topic - 分布式消息服务Kafka版
huaweicloud.sdk.kafka.v2.region.KafkaRegion; import com.huaweicloud.sdk.kafka.v2.*; import com.huaweicloud.sdk.kafka.v2.model.*; import java