-
查询实例的后台任务列表 - 分布式消息服务Kafka版
表2 Query参数 参数 是否必选 参数类型 描述 start 否 Integer 开启查询的任务编号。 limit 否 Integer 查询的任务个数。 begin_time 否 String 查询任务的最小时间,格式为YYYYMMDDHHmmss。
-
查询实例在CES的监控层级关系 - 分布式消息服务Kafka版
", "broker_bytes_in_rate", "broker_produce_mean", "broker_fetch_mean"], "key_name": ["nodes"], "dim_router": ["kafka_instance_id",
-
查询所有消费组 - 分布式消息服务Kafka版
(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer
-
查询Topic的当前生产者列表 - 分布式消息服务Kafka版
响应参数 状态码: 200 表3 响应Body参数 参数 参数类型 描述 total Integer 总条数 producers Array of producers objects 生产者列表 表4 producers 参数 参数类型 描述 producer_address String
-
重置消费组消费进度到指定位置 - 分布式消息服务Kafka版
) print(e.error_msg) 重置的消费进度到指定时间。
-
重置消费组消费进度到指定位置 - 分布式消息服务Kafka版
partition Integer 否 分区编号,默认值为-1,若传入值为-1,则重置所有分区。
-
Kafka体验版使用说明 - 分布式消息服务Kafka版
Kafka体验版使用说明 Kafka体验版实例规格为EXP,为单代理实例,不支持Kafka Manager、Smart Connect和多AZ等功能。 Kafka体验版实例只适用体验和业务测试场景,无法保证性能和可靠性。
-
审计与日志 - 分布式消息服务Kafka版
审计与日志 云审计服务(Cloud Trace Service,简称CTS),是华为云安全解决方案中专业的日志审计服务,提供对各种云资源操作记录的收集、存储和查询功能,可用于支撑安全分析、合规审计、资源跟踪和问题定位等常见应用场景。
-
重置消费组消费进度到指定位置 - 分布式消息服务Kafka版
) print(e.error_msg) 重置的消费进度到指定时间。
-
版本支持公告 - 分布式消息服务Kafka版
EOS:End of Service & support,停止该版本的服务,建议您在执行作业时选择最新版本的引擎。在该日期之后,不再提供该软件版本的任何技术服务支持。 父主题: 版本公告
-
业务数据不均衡处理建议 - 分布式消息服务Kafka版
Kafka扩容了Broker节点,新增的节点没有分配分区,会导致节点间的数据不均衡。 业务使用过程中随着集群状态的变化,多少会发生一些Leader副本的切换或迁移,会导致个别Broker节点上的数据更多,从而导致节点间的数据不均衡。
-
诊断Kafka消息积压 - 分布式消息服务Kafka版
在“诊断维度”区域,单击包含异常项的维度名称,例如:重平衡,查看导致异常的可能原因、受影响的分区或者broker,以及解决消息堆积的建议。 父主题: 管理消息
-
查看和重置Kafka消费进度 - 分布式消息服务Kafka版
/kafka-consumer-groups.sh --bootstrap-server ${connection-address} --offsets --describe --all-groups --command-config .
-
计费项 - 分布式消息服务Kafka版
计费示例 以包年/包月计费模式为例,假设您于2023/03/08 15:50:04在“华北-北京四”区域购买了一个包年/包月Kafka实例(规格:kafka.2u4g.cluster*3,总存储空间:超高I/O 300GB),计费资源包括实例费用(代理规格和代理数量),以及存储空间费用
-
消费者消费Topic失败,提示没有权限? - 分布式消息服务Kafka版
问题原因:消费组的leader在进行分区分配时,不会考虑某一个消费者的授权和订阅信息,只会根据消费组整体的订阅情况进行分区分配,此种情况下可能会给消费者分配到未授权的Topic,从而导致了上述问题的出现。
-
责任共担 - 分布式消息服务Kafka版
华为云的安全责任在于保障其所提供的 IaaS、PaaS 和 SaaS 类云服务自身的安全,涵盖华为云数据中心的物理环境设施和运行其上的基础服务、平台服务、应用服务等。这不仅包括华为云基础设施和各项云服务技术的安全功能和性能本身,也包括运维运营安全,以及更广义的安全合规遵从。
-
SDK概述 - 分布式消息服务Kafka版
在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能,降低您使用SDK的难度,推荐使用。 SDK列表 表1提供了分布式消息服务Kafka版支持的SDK列表,您可以在GitHub仓库查看SDK更新历史、获取安装包以及查看指导文档。
-
业务过载处理建议 - 分布式消息服务Kafka版
"org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer
-
配置Kafka流控 - 分布式消息服务Kafka版
进入“流控管理 > 流控列表”页面,在“User/Client”页签中,单击页面左上角的“仅设置了用户名”/“仅设置了客户端ID”/“设置了用户名和客户端ID”,输入新创建的流控名称,按“Enter”,查看新创建的流控。
-
收集连接信息 - 分布式消息服务Kafka版
图1 查看Kafka实例Broker连接地址与端口 Topic名称 从Kafka实例控制台的Topic管理页面中获取Topic名称。 SASL信息 如果实例开启密文接入,则需要获得连接实例的用户名与密码、Kafka安全协议和SASL认证机制。