检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Kafka实例开启密文接入后，支持对Topic进行ACL（Access Control List）权限管理，您可以在Topic中为不同的用户设置不同的生产消费消息的权限，以达到用户之间的权限隔离。 本章节主要介绍Kafka实例开启密文接入后，如何对Topic进行用户授权。 约束与限制 如果“allow
Kafka不能保证消费重复的消息，业务侧需保证消息处理的幂等性。 消费线程退出要调用consumer的close方法，避免同一个组的其他消费者阻塞session.timeout.ms的时间。 消费组名称开头不使用特殊字符（如#），使用特殊字符可能会导致云监控无法展示此消费组的监控数据。 producer使用建议
Manager。 在待重启Manager的Kafka实例所在行，单击“更多 > 重启Manager”。 单击Kafka实例名称，进入实例详情页面。单击右上角的“更多 > 重启Manager”。 单击“是”。 您可以在实例的“后台任务管理”页面，查看当前任务的操作进度。任务状态为“成功”，表示重启成功。
关闭Kafka Manager Kafka Manager会占用额外的内存和CPU资源，关闭Kafka Manager可以减少这部分资源的占用。本章节指导您在控制台关闭Kafka Manager。 约束与限制 Kafka Manager关闭后，无法再次开启。 关闭Kafka Manager，不会重启实例。
在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 在左侧导航栏单击“Kafka实例”，进入Kafka实例列表页面。 单击Kafka实例的名称，进入实例详情页面。 在左侧导
删除Kafka实例 对于按需计费的Kafka实例，控制台支持删除单个实例，也可批量删除实例。对于包年/包月的Kafka实例，如果不再使用，单击“操作”栏下的“更多 > 退订”，退订成功后，Kafka实例会自动被删除。 删除的实例能否恢复取决于是否开启回收站策略，如果未开启回收站策
重置Kafka Manager密码 如果您忘记了创建实例时设置的Kafka Manager密码，通过重置Manager密码功能，重新设置一个新的密码，可使用新密码登录Kafka Manager。 2023年5月17日及以后创建的实例不提供重置Kafka Manager密码功能。 前提条件
消息Key 输入消息的Key。 发送到指定分区 选择是否开启消息发送到指定的分区。 关闭：消息基于Key的hash值选择分区。 开启：消息将发送到指定的分区内。开启“发送到指定分区”后，需要选择分区ID。 单击“确定”，完成消息的发送。 消息发送成功后，您可以在“消息查询”页面，查看已成功发送的消息。
带宽速率：统计带宽速率大于x MB/s的用户/客户端/Topic，x由您自行输入。 带宽使用量：统计带宽使用量超过x %的用户/客户端/Topic，x由您自行输入。 统计类型 设置带宽使用量的统计类型。 生产：统计生产消息的带宽使用量。 消费：统计消费消息的带宽使用量。 统计维度 设置带宽使用量的统计维度。
关闭Smart Connect后，实例会停止收取用于Smart Connect的代理费用，并自动删除用于Smart Connect的代理。 关闭Smart Connect后，再重新开启Smart Connect，已删除的Smart Connect任务无法找回，需要重新创建。 单机实例不支持关闭Smart
factor”（副本数）或“num.partitions”（分区数）的参数值，单机实例不支持修改配置参数。修改参数值后自动创建的Topic，Topic参数值为修改后的值。 例如：“num.partitions”修改为“5”，自动创建的Topic参数值如表1所示。 表1 Topic参数值 参数名称
Topic详情页面显示Topic的基本信息、订阅关系、分区信息和生产者信息。 基本信息：包含Topic名称、关联代理、分区数和创建时间。 创建Topic的时间或方式满足以下任意一种情况时，Topic详情页面不显示创建时间。 2023年7月10日以及之前创建的Topic。 自动创建的Topic、在客
CreateTime：生产者创建消息的时间。 LogAppendTime：broker将消息写入日志的时间。 批处理消息最大值 Kafka允许的最大批处理大小，如果启用消息压缩，则表示压缩后的最大批处理大小。 如果增加“批处理消息最大值”的值，且存在消费者版本早于0.10.2，此时消费者的“fetch
输入的偏移量为5，此时会删除偏移量为2到4的消息。 请注意以下几点： 如果“偏移量”设置为“-1”，表示删除分区中所有的消息。 如果您输入的偏移量不在指定分区的最早偏移量和最晚偏移量之间，消息将不会被删除。 如果需要删除多个分区的消息，单击“添加分区”，设置需要删除消息的分区和偏移量。每次最多可选择10个分区。
升级Kafka实例内核版本指的是将老的内核版本升级到最新的内核版本，升级后，Kafka实例将支持一些新的特性（例如支持在控制台创建消费组、支持查看Topic详情等），并且修复老版本的一些问题。 升级Kafka实例内核版本并非升级Kafka实例的版本，例如升级前Kafka版本为2.
消费者是从Topic订阅消息的一方，消费组是由一个或多个消费者组成的。同一个消费组内，一个消费者可同时消费多个分区，但一个分区在同一时刻只能被一个消费者消费。 图1 消费关系示例图 “auto.create.groups.enable”表示在消费者进入未创建的消费组时，会自动创建此消费组。
60000 ms错误 问题现象 多可用区的Kafka实例，在某个可用区故障后，Kafka客户端在生产或消费消息时，可能会报Topic {{topic_name}} not present in metadata after 60000 ms的错误，如下图所示。 问题解决措施 以下三
单机实例不支持开启SASL_SSL。 启用的安全协议 开启SASL_SSL后，实例已启用的安全协议。 开启的SASL认证机制 开启SASL_SSL后，实例已开启的SASL认证机制。 SSL证书 单击“下载”，下载连接实例的SSL证书。 内网连接地址 未开启公网访问时，连接实例的地址。 显示的连接地址个数为实例代理个数。
fmt.Println(err) } } 更多编程语言的SDK代码示例，请参见API Explorer的代码示例页签，可生成自动对应的SDK代码示例。 状态码 状态码 描述 200 查询实例集群的所有消费组成功。 错误码 请参见错误码。 父主题： 消费组管理
for Kafka通过多种数据保护手段和特性，保障DMS for Kafka的数据安全可靠。 表1 DMS for Kafka的数据保护手段和特性 数据保护手段 简要说明 详细介绍 容灾和多活 根据对数据与服务的不同可靠性要求，您可以选择在单可用区内（单机房）部署Kafka实例，或跨
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
