检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
消息积压诊断”，进入消息积压诊断页面。 选择需要诊断的消费组名称和Topic名称，单击“诊断前检查”。 诊断前检查成功后，如果“消息积压情况”显示有消息积压，并且消费组正在以非assign方式消费消息中，单击“开始诊断”。 诊断成功后，在诊断记录所在行，单击“查看详情”，进入“诊断详情”页面，查看导致消息堆积的可
连接信息”中获取实例连接地址。Kafka实例连接地址在Kafka控制台存在两种不同的显示，一种为“内网连接地址”/“公网连接地址”，另一种为“内网密文连接地址”/“公网密文连接地址”，具体以控制台显示为准。 如果是使用内网通过同一个VPC访问，Kafka连接地址如下图所示。 图1
https://{endpoint}/v2/kafka/products/cores 响应示例 状态码： 200 查询成功。 { "core_num" : 100 } 状态码 状态码 描述 200 查询成功。 错误码 请参见错误码。 父主题： 其他接口
"maintain_end":"06:00:00" } 响应消息 响应参数 无。 响应样例 无。 状态码 操作成功的状态码如表3所示，其他响应见状态码。 表3 状态码 状态码 描述 204 修改实例成功。 父主题： 实例管理类接口
执行如下命令使修改生效。 source .bash_profile 查看Java JDK是否安装成功。 java -version 回显信息中包含如下信息，表示Java JDK安装成功。 java version "1.8.0_321" 下载开源的Kafka客户端。 wget https://archive
配置参数，请参考Kafka配置进行修改。 Kafka实例的参数分为动态参数和静态参数： 动态参数：动态参数修改成功后，无需重启实例，立即生效。 静态参数：静态参数修改成功后，需要手动重启实例才能生效。 约束与限制 部分老实例不支持修改配置参数，具体以控制台为准，请联系客服解决。 单机实例不支持修改配置参数。
ance_id}/groups 响应示例 状态码： 200 操作成功。 { "job_id" : "8a2c259182ab0e9d0182ab1882560010" } 状态码 状态码 描述 200 操作成功。 错误码 请参见错误码。 父主题： 消费组管理
修改Kafka消费组信息 消费组创建成功后，您可以根据业务需要修改消费组的描述信息。 修改Kafka消费组信息 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
SASL认证机制如何修改？ Kafka实例的SASL认证机制包括SCRAM-SHA-512和PLAIN。 密文接入成功开启后，不支持修改SASL认证机制。如果需要修改，请重新创建实例。 父主题： 实例问题
中输入关键字，按“Enter”，界面显示相应时间段内启动的任务。 在后台任务管理页面，您还可以执行以下操作： 单击，刷新任务状态。 单击“删除”，弹出“删除任务记录”对话框，单击“确定”，清理任务信息。 只有在任务已经执行完成，即任务状态为成功或者失败，或者定时任务已经取消，即任务状态为取消，才能执行删除操作。
200 删除消息成功。 { "partitions" : [ { "partition" : 0, "result" : "success", "error_code" : 0 } ] } 状态码 状态码 描述 200 删除消息成功。 错误码 请参见错误码。
Kafka的消费组删除了，怎么监控页面还可以看到这个消费组？ 监控数据是每分钟进行采集上报，上报的数据经过整理后才会显示在监控页面上，此过程大约需要几分钟到十几分钟，建议您在删除消费组后，过一段时间再去监控页面查看。 父主题： 监控告警问题
ct_id}/instances/{instance_id}/groups/{group} 响应示例 状态码： 200 查询指定消费组信息成功。 { "group" : null, "members" : [ { "host" : "/172.31.1.102",
ct_id}/instances/{instance_id}/groups/{group}/topics 响应示例 状态码： 200 查询成功。 { "topics" : [ { "topic" : "topic-1", "partitions" : 1,
量相同的弹性IP地址，单击，跳转到“后台任务管理”页面。 当任务状态显示为“成功”时，表示成功开启公网访问。 图2 开启公网访问 开启公网访问后，需要设置接入方式（明文接入、密文接入）和对应的安全组规则，才能成功连接Kafka。连接Kafka的具体操作请参考连接实例。 表3 Ka
单击“确定”，弹出“替换SSL证书”对话框。 单击“确认”，完成证书的替换。 在“后台任务管理”页面，替换SSL证书任务的“状态”为“成功”时，表示替换证书成功。 证书替换成功后，在实例详情页单击“下载”，下载的证书为分布式消息服务Kafka版提供的证书，并非您自己制作的证书。 步骤三：修改客户端配置文件
t_id}/instances/{instance_id}/groups/{group}/members 响应示例 状态码： 200 查询成功。 { "members" : [ { "member_id" : "consumer-1-6b8ee551-d499-47d
请求示例 GET https://{endpoint}/v1.0/{project_id}/quotas/dms 响应示例 状态码： 200 查询成功。 { "quotas" : { "resources" : [ { "type" : "rabbitmqInstance"
project_id}/instances/{instance_id}/groups 响应示例 状态码： 200 查询实例集群的所有消费组成功。 { "groups" : [ { "createdAt" : 1691401194847, "group_id" :
在“实例信息”区域的“Kafka自动创建Topic”后，单击或，弹出“确认”对话框。 单击“确定”，跳转到“后台任务管理”页面。任务状态为“成功”时，表示开启/关闭Kafka自动创建Topic成功。 父主题： Topic管理
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
