检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
删除用户/客户端流控配置 功能介绍 该接口用于向Kafka实例提交删除用户、客户端级别的流控任务，若成功则返回流控任务的job_id。 调用方法 请参见如何调用API。 URI DELETE /v2/kafka/{project_id}/instances/{instance_i
创建用户/客户端流控配置 功能介绍 该接口用于向Kafka实例提交创建用户、客户端级别的流控任务，若成功则返回流控任务的job_id。 调用方法 请参见如何调用API。 URI POST /v2/kafka/{project_id}/instances/{instance_id}
查看监控指标与配置告警 查看Kafka监控数据 Kafka支持的监控指标 配置Kafka监控告警
要设置带宽限制，建议该参数值不小于待分区平衡Topic的总生产带宽 * 待分区平衡Topic的最大副本数。 带宽限制值的估算方法，请参考带宽限制值估算方法。 执行时间 选择分区平衡任务执行的时间。 立即执行：表示立即执行分区平衡任务。 定时执行：表示在指定的时间执行分区平衡任务。
代理上。 将高负载代理上的Leader分区切换为Follower。 在修改分区平衡过程中，可以配置增加/减少Topic的副本数。 分布式消息服务Kafka版控制台提供两种分区平衡的方法：自动平衡和手动平衡，建议选择自动平衡，确保分区Leader的均匀分布。 操作视频 本视频演示修改Kafka实例分区平衡的操作。
fka实例。 参考Java客户端接入示例，连接Kafka实例生产消费消息。其中，生产消息配置文件和消费消息配置文件中的SASL信息修改为如下内容。 #SASL认证机制为“PLAIN”时，配置信息如下。 sasl.mechanism=PLAIN sasl.jaas.config=org
分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 在左侧导航栏单击“Kafka实例”，进入Kafka实例列表页面。 通过以下任意一种方法，查看监控数据。 在Kafka实例名称后，单击“查看监控数据”。跳转到云监控页面，查看监控数据，数据更新周期为1分钟。 单击Kafka实例
found”在配置参数中修改。 如果“allow.everyone.if.no.acl.found”设置为“false”，只有授权的用户可以订阅/发布此Topic，其他未授权的用户不能订阅/发布此Topic。“allow.everyone.if.no.acl.found”在配置参数中修改。
修改用户/客户端流控配置 功能介绍 该接口用于向Kafka实例提交修改用户、客户端级别的流控任务，若成功则返回流控任务的job_id。 调用方法 请参见如何调用API。 URI PUT /v2/kafka/{project_id}/instances/{instance_id}/
Topic详情 修改Kafka Topic配置 修改Kafka Topic分区数 修改Kafka Topic副本数 导出Kafka Topic列表 修改Kafka分区平衡 配置Kafka自动创建Topic 删除Kafka Topic 父主题： 配置Topic
开启公网访问后，在哪查看公网IP地址？ 在Kafka控制台，单击Kafka实例名称，进入实例详情页面。在“基本信息”页签，查看公网IP地址（即“公网连接地址”）。 如果您需要连接Kafka实例，请参考连接Kafka。 父主题： 连接问题
Kafka实例的内网连接地址可以修改吗？ 不支持修改，且不支持指定IP地址。 父主题： 连接问题
当分区中的消息都已老化，或尚未生产消息时，“最早更新时间”和“最近更新时间”显示“--”，如下图所示。 图2 分区信息 生产者信息：包含Broker地址、生产者地址和加入时间。 2023年7月10日以及之前创建的Topic，在Topic详情页面不显示“生产者”页签。 父主题： Topic管理
在Windows主机中，解压Logstash压缩包，进入“config”文件夹，创建“output.conf”配置文件。 图3 创建“output.conf”配置文件 在“output.conf”配置文件中，增加如下内容，连接Kafka实例。 input { stdin {} } output
消费线程退出要调用consumer的close方法，避免同一个组的其他消费者阻塞session.timeout.ms的时间。 消费组名称开头不使用特殊字符（如#），使用特殊字符可能会导致云监控无法展示此消费组的监控数据。 producer使用建议 同步复制客户端需要配合使用：acks=all 配置发送失败重试：retries=3
[root@ecs-kafka bin]# 已开启密文接入的Kafka实例，通过以下步骤查询消费者列表。 （可选）修改客户端配置文件。 在Kafka控制台的“基本信息 > 连接信息”中查看Kafka安全协议，两种安全协议对应的配置文件设置有所不同，请根据实际情况配置。 SASL_
查看Kafka流控统计 如果Kafka配置了流量控制，可在控制台查看当前流控策略下，每个代理上用户/客户端/Topic的带宽使用量。 约束与限制 单机实例不支持查看流控监控。 查看带宽使用量 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件
Kafka实例的连接地址默认有多少个？ Kafka实例的连接地址个数和实例的代理个数有关，连接地址个数即为代理个数。每类实例规格对应的代理个数如下表所示。 表1 Kafka集群实例规格 规格名称 代理个数范围 单个代理TPS 单个代理分区上限 单个代理建议消费组数 单个代理客户端总连接数上限
- [root@ecs-kafka bin]# 已开启密文接入的Kafka实例，通过以下步骤查询消费进度。 （可选）修改客户端配置文件。 在Kafka控制台的“基本信息 > 连接信息”中查看Kafka安全协议，两种安全协议对应的配置文件设置有所不同，请根据实际情况配置。 SASL_
broker_cpu_core_load CPU核均负载 该指标为从Kafka节点虚拟机层面采集的CPU每个核的平均负载。 单位：% 0~20 Kafka实例节点 1分钟 broker_disk_usage 磁盘容量使用率 该指标为从Kafka节点虚拟机层面采集的磁盘容量使用率。 单位：% 0~100% Kafka实例节点
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
