检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
排查思路:如果是Java语言客户端,建议排查GC日志是否存在长时间FullGC的情况。该场景可能会导致心跳线程阻塞,服务端检查心跳失败,进入Rebalance状态。 解决方法:如果存在长时间FullGC的情况,需要您排查客户端相关问题(FullGC可能是客户端存在内存泄露)。 场景二:消费者消费时间间隔过长
订阅关系:包含消费组名称、消费组状态、Coordinator(ID)和堆积数。 单击消费组名称,跳转到对应消费组的详情页面。 如果一个实例中消费组数量超过10000,则不支持查询Topic的订阅关系。 图1 订阅关系 分区信息:包含分区编号、最小偏移量、最大偏移量、消息数和消息更新时间。 图2
功能说明 本章节定义了分布式消息服务Kafka版上报云监控服务的监控指标的命名空间,监控指标列表和维度定义,您可以通过云监控服务的管理控制台或API接口来检索Kafka实例产生的监控指标和告警信息,也可以通过分布式消息服务Kafka版控制台提供的“监控”页面来检索Kafka实例产生的监控指标。
段,资源状态为“运行中”。 到期后,资源状态变为“已过期”。 到期未续费时,Kafka实例首先会进入宽限期,宽限期到期后仍未续费,资源状态变为“已冻结”。 超过宽限期仍未续费将进入保留期,如果保留期内仍未续费,资源将被自动删除。 华为云根据客户等级定义了不同客户的宽限期和保留期时长。
"id" : "aabb", "success" : true } ] } 状态码 操作成功的状态码如表5所示,其他响应见状态码。 表5 状态码 状态码 描述 200 删除成功。 父主题: 实例管理类接口
PLAIN机制、用户名和密码,单击“确定”。跳转到“后台任务管理”页面。当任务状态显示为“成功”时,表示成功开启密文接入。 说明: 首次开启密文接入(包括内网访问密文接入和公网访问密文接入)时,需要设置kafka安全协议、SASL PLAIN机制、用户名和密码,再次开启时,只需要设置kafka安全协议。
s/{instance_id}/password { "new_password" : "********" } 响应示例 无 状态码 状态码 描述 204 重置密码成功。 错误码 请参见错误码。 父主题: 实例管理
1 ] } ] } 响应消息 响应参数 无 响应示例 无 状态码 操作成功的状态码。 表4 状态码 状态码 描述 204 调整副本操作成功。 父主题: 实例使用类接口
Query参数 参数 是否必选 参数类型 描述 engine 是 String 消息引擎的类型。当前只支持Kafka类型。 请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 Hourly Array of Hourly objects 表示按需付费的产品列表。
AT规则。 图4 添加DNAT规则 单击“确定”,完成DNAT规则的添加。 DNAT规则添加成功后,在DNAT规则列表中查看此规则的状态,若“状态”为“运行中”,表示创建成功。 为获取Kafka实例的信息中记录的其他内网连接地址创建DNAT规则,每个DNAT规则需要设置不同的弹性公网IP。
约束与限制 按需计费Kafka实例绑定的云硬盘随Kafka实例同步变更计费模式。 前提条件 Kafka实例计费模式为“按需计费”。 Kafka实例状态为“运行中”。 操作步骤 登录管理控制台。 单击左侧导航栏的图标,选择“应用中间件 > 分布式消息服务Kafka版”。 通过以下任意一种方法,实现按需实例转包周期。
"67fc5f8d-3986-4f02-bb75-4075a23112de" } ] } 状态码 操作成功的状态码如表5所示,其他响应见状态码。 表5 状态码 状态码 描述 200 重启或者删除实例成功。 204 删除创建失败实例成功。 父主题: 实例管理类接口
jks”、“server.truststore.jks”和“client.truststore.jks”到本地PC机。 “server.keystore.jks”和“server.truststore.jks”在后续步骤“替换证书”时,用来替换“Keystore文件”和“Truststore文件”。“client
"enable_auto_topic": true } ], "instance_num": 1 } 状态码 操作成功的状态码如表5所示,其他响应见状态码。 表5 状态码 状态码 描述 200 查询所有实例列表成功。 父主题: 实例管理类接口
消费组问题 Kafka实例是否需要创建消费组、生产者和消费者? 如果消息组中没有在线的消费者(如empty状态),是否14天后会自动被删除? 客户端删除消费组后,在Kafka Manager中仍可以看到此消费组? 为什么删除消费组不生效? 实例消费正常,为什么看不到消费者? Ka
至少包含以下字符中的3种: 大写字母 小写字母 数字 特殊字符`~!@#$%^&*()-_=+\|[{}];:'",<.>/? 和空格,并且不能以-开头。 响应参数 无 请求示例 重置Kafka Manager的密码。 PUT https://{endpoint}/v2/{project
sasl.mechanism=PLAIN 参数说明如下:username和password为首次开启密文接入时填入的用户名和密码,或者创建用户时设置的用户名和密码。 SASL_SSL:如果已经设置了用户名和密码,以及SSL证书配置,请跳过此步骤,执行2。否则在Kafka客户端的“
这种方案适用于对消费消息的实时性要求不高的应用场景。如果要求准实时消费消息,则建议保持所有消费者处于活跃状态。 图2 优化后的多线程消费方案 消费者(Consumer)和消息分区(Partition)并不强制数量相等,Kafka的poll(long)方法帮助实现获取消息、分区平衡、消费者与Kafka
义规格和自定义特性,您可以根据业务需要定制相应计算能力和存储空间的Kafka实例。 操作视频 本视频演示自定义购买Kafka实例的操作。 准备实例依赖资源 创建Kafka实例前,请提前准备好如表1所示资源。 表1 Kafka实例依赖资源 资源名称 要求 创建指导 VPC和子网 K
id. Engine和ProductID不匹配。 请检查参数engine 400 DMS.00400026 This operation is not allowed due to the instance status. 当前的实例状态不支持该操作。 请检查实例状态 400 DMS