-
Kafka客户端使用建议 - 分布式消息服务Kafka版
塞sesstion.timeout.ms的时间。 消费组名称开头不使用特殊字符(如#),使用特殊字符可能会导致云监控无法展示此消费组的监控数据。 producer使用建议 同步复制客户端需要配合使用:acks=all 配置发送失败重试:retries=3 发送优化:对于时延敏感的信息,设置linger
-
查询消费组信息 - 分布式消息服务Kafka版
String 消费组名称。 state String 消费组状态。包含以下状态: Dead:消费组内没有任何成员,且没有任何元数据。 Empty:消费组内没有任何成员,存在元数据。 PreparingRebalance:准备开启rebalance。 CompletingRebalance:所有成员加入group。
-
修改Kafka实例配置参数 - 分布式消息服务Kafka版
unclean.leader.election.enable 指示是否启用不在ISR集合中的副本选为领导者作为最后的手段,即使这样做可能导致数据丢失。 true/false false connections.max.idle.ms 此参数用来指定在多少毫秒之后,关闭空闲的连接。 5000
-
使用客户端连接Kafka(密文接入) - 分布式消息服务Kafka版
数来修改单IP的连接数,即修改max.connections.per.ip参数值。 如果实例开启了VPC内网明文访问,使用内网连接实例时,数据将使用明文传输,连接步骤请参考使用客户端连接Kafka(明文接入)。 前提条件 已配置正确的安全组。 访问开启密文接入的Kafka实例时,
-
修改转储任务的配额 - 分布式消息服务Kafka版
是 String 项目ID,获取方式请参见获取项目ID。 connector_id 是 String 实例转储ID。 请参考查询实例返回的数据。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 sink_max_tasks 是 Integer 转储任务的总个数。
-
Java开发环境搭建 - 分布式消息服务Kafka版
serializer=org.apache.kafka.common.serialization.StringSerializer #producer可以用来缓存数据的内存大小 buffer.memory=33554432 #重试次数 retries=0 #######################
-
删除单个转储任务 - 分布式消息服务Kafka版
是 String 项目ID,获取方式请参见获取项目ID。 connector_id 是 String 实例转储ID。 请参考查询实例返回的数据。 task_id 是 String 转储任务ID。 请求参数 无 响应参数 无 请求示例 删除指定的转储任务。 DELETE https
-
使用客户端连接Kafka(明文接入) - 分布式消息服务Kafka版
文件中指定了消费组名称,请确保命令行中的消费组名称与配置文件中的相同,否则可能消费失败。消费组名称开头包含特殊字符,例如#号“#”时,监控数据无法展示。 示例如下: [root@ecs-kafka bin]# ./kafka-console-consumer.sh --bootstrap-server
-
查询转储任务列表 - 分布式消息服务Kafka版
是 String 项目ID,获取方式请参见获取项目ID。 connector_id 是 String 实例转储ID。 请参考查询实例返回的数据。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 tasks Array of tasks objects
-
构造请求 - 分布式消息服务Kafka版
查询参数,是可选部分,并不是每个API都有查询参数。查询参数前面需要带一个“?”,形式为“参数名=参数取值”,例如“?limit=10”,表示查询不超过10条数据。 例如您需要获取IAM在“华北-北京四”区域的Token,则需使用“华北-北京四”区域的Endpoint(iam.cn-north-4.myhuaweicloud
-
权限管理 - 分布式消息服务Kafka版
删除、扩容、转储)。 系统策略 无 DMS ReadOnlyAccess 分布式消息服务的只读权限,拥有该权限的用户仅能查看分布式消息服务数据。 系统策略 无 DMS VPCAccess 分布式消息服务租户委托时需要授权的VPC操作权限。 系统策略 无 DMS KMSAccess
-
查询消息 - 分布式消息服务Kafka版
消息大小。 timestamp Long 生产消息的时间。 格式为Unix时间戳。单位为毫秒。 huge_message Boolean 大数据标识。 message_offset Long 消息偏移量。 message_id String 消息ID。 app_id String 应用ID。
-
Kafka实例查询Topic - 分布式消息服务Kafka版
policiesOnly Boolean 是否为默认策略。 name String topic名称。 replication Integer 副本数,配置数据的可靠性。 partition Integer topic分区数,设置消费的并发数。 retention_time Integer 消息老化时间。
-
Kafka实例创建Topic - 分布式消息服务Kafka版
topic名称,长度为3-200,以字母开头且只支持大小写字母、中横线、下划线、点以及数字。 replication 否 Integer 副本数,配置数据的可靠性。 取值范围:1-3。 sync_message_flush 否 Boolean 是否使用同步落盘。默认值为false。同步落盘会导致性能降低。
-
开启Smart Connect(按需实例) - 分布式消息服务Kafka版
是否必选 参数类型 描述 specification 否 String 部署Smart Connect的规格,基准带宽,表示单位时间内传送的最大数据量。请保持和当前实例规格一致。仅老规格实例需要填写。 取值范围: 100MB 300MB 600MB 1200MB node_cnt 否 String
-
测试Kafka实例TPS - 分布式消息服务Kafka版
servers=${连接地址} acks=1 batch.size=16384 linger.ms=10 --topic ${Topic名称} --num-records 10000000 --record-size 1024 --throughput -1 --producer.config ../config/producer
-
查看Kafka审计日志 - 分布式消息服务Kafka版
extendDMSInstanceTaskFailure 提交重置DMS实例密码请求成功 kafka resetDMSInstancePasswordSuccess 提交重置DMS实例密码请求失败 kafka resetDMSInstancePasswordFailure 提交重启DMS实例请求成功
-
重置Manager密码 - 分布式消息服务Kafka版
com.huaweicloud.sdk.kafka.v2.model.*; public class ResetManagerPasswordSolution { public static void main(String[] args) { // The
-
重置密码 - 分布式消息服务Kafka版
import com.huaweicloud.sdk.kafka.v2.model.*; public class ResetPasswordSolution { public static void main(String[] args) { // The