检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
CreateKafkaUserClientQuotaTaskReq{ ConsumerByteRate: &consumerByteRateCreateKafkaUserClientQuotaTaskReq, ProducerByteRate: &producerByteRateCre
response, err := client.DeleteBackgroundTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
&clientDeleteKafkaUserClientQuotaTaskReq, User: &userDeleteKafkaUserClientQuotaTaskReq, } response, err := client.DeleteKafkaUserClientQuotaTask(request)
response, err := client.ResetPassword(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) }
response, err := client.ShowInstanceConfigs(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
ShowKafkaUserClientQuotaRequest{} request.InstanceId = "{instance_id}" response, err := client.ShowKafkaUserClientQuota(request) if err == nil
&model.DeleteInstanceRequest{} request.InstanceId = "{instance_id}" response, err := client.DeleteInstance(request) if err == nil {
描述 total Integer 参数解释： 总条数。 取值范围： 0~10000。 producers Array of producers objects 参数解释： 生产者列表。 表4 producers 参数 参数类型 描述 producer_address String
消息总数。 offsets_count Integer 总页数。 offset Integer 当前页数。 表3 messages参数说明 参数 类型 说明 topic String topic名称。 partition Integer 分区编号。 message_offset Long
未开启公网访问时，连接实例的地址。 显示的连接地址个数为实例代理个数。 Manager内网访问地址 未开启公网访问时，连接Kafka Manager的地址。 2023年5月17日及以后创建的实例不提供此地址。 Manager用户名 连接Kafka Manager的用户名。 2023年5月17日及以后创建的实例不提供此用户名。
UpdateKafkaUserClientQuotaTaskReq{ ConsumerByteRate: &consumerByteRateUpdateKafkaUserClientQuotaTaskReq, ProducerByteRate: &producerByteRateUpd
kafka_broker（kafka节点维度） broker_data_size 节点数据容量 broker_messages_in_rate 消息生产速率，每秒生产的消息数量 broker_bytes_out_rate 消费流量，每秒消费的字节数 broker_bytes_in_rate
Kafka单机实例由一个代理组成，兼容开源Kafka 2.7版本，适用于测试场景，不建议用于生产业务。 关于下表中TPS的说明： TPS（Transaction per second）：在Kafka场景中，指每秒能写入到Kafka实例的最大消息数量。 TPS性能：是指以1KB大小的消息为例的每秒处理消息条数。
ListInstanceConsumerGroupsRequest{} request.InstanceId = "{instance_id}" response, err := client.ListInstanceConsumerGroups(request) if err == nil {
2u4g.cluster.small 3~30 20000 100 15 2000 300~300000 40 kafka.2u4g.cluster 3~30 30000 250 20 2000 300~300000 100 kafka.4u8g.cluster 3~30 100000
2027年3月 3.x 在售 2024年4月 暂无计划 暂无计划 EOM：End of Marketing，停止该版本的销售。 EOS：End of Service & support，停止该版本的服务，建议您在执行作业时选择最新版本的引擎。在该日期之后，不再提供该软件版本的任何技术服务支持。
Kafka实例不支持在线重置消费进度。在执行重置消费进度之前，必须停止被重置消费组客户端。 在停止被重置消费组客户端后，需要经过ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间（默认10000毫秒），服务端才认为消费组客户端真正下线。 URI
项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 start 否 Integer 开启查询的任务编号。 limit 否 Integer 查询的任务个数。 begin_time 否 String 查询任务的最小时
Kafka体验版使用说明 Kafka体验版实例规格为EXP，为单代理实例，不支持Kafka Manager、Smart Connect和多AZ等功能。 Kafka体验版实例只适用体验和业务测试场景，无法保证性能和可靠性。如果需要在生产环境使用Kafka实例，建议购买按需或包年包月的Kafka实例。
审计与日志 云审计服务（Cloud Trace Service，简称CTS），是华为云安全解决方案中专业的日志审计服务，提供对各种云资源操作记录的收集、存储和查询功能，可用于支撑安全分析、合规审计、资源跟踪和问题定位等常见应用场景。 用户开通云审计服务并创建和配置追踪器后，CTS可记录DMS
