检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
objects kafka配置列表。 表3 InstanceConfig 参数 参数类型 描述 name String 配置名称。 valid_values String 有效值。 default_value String 默认值。 config_type String 配置类型：static/dynamic。
fka实例前，请先创建开启弹性公网IP的ECS、安装JDK、配置环境变量以及下载Kafka开源客户端。 登录管理控制台，在左上角单击，选择“计算 > 弹性云服务器”，创建一个ECS实例。 创建ECS的具体步骤，请参考购买弹性云服务器。如果您已有可用的ECS，可重复使用，不需要再次创建。
步骤五：验证接口连通性 参考使用客户端连接Kafka（关闭SASL）或者使用客户端连接Kafka（开启SASL），测试是否可以生产和消费消息。 测试接口连通性时，注意以下几点： 连接Kafka实例的地址为“advertised.listeners IP:9011”，以图8为例，连接Kafka实例的地址为“192
在“立即执行”中，选择任务创建后是否立即执行任务，默认开启立即执行。如果关闭，在需要执行此任务时，您可以在Smart Connect任务列表中手动开启任务。 在“源端配置”中，保持默认设置。 在“Topic配置”中，设置以下参数。 表1 Topic配置参数说明 参数 参数说明 正则表达式 表示
100 获取测试工具。 获取Kafka命令行工具2.7.2版本。 购买客户端服务器。 购买1台ECS服务器（区域、可用区、虚拟私有云、子网、安全组与Kafka实例保持一致，Linux系统），具体步骤请参考购买弹性云服务器。 购买完成ECS后，需要在ECS中完成以下配置： 安装Java
由任意语种字母、数字、空格和字符组成，字符仅支持_ . : = + - @ 创建实例时设置的标签值，首尾字符不能为空格。 配置Kafka实例标签 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息
配置消息堆积数监控 方案概述 在消息处理过程中，如果客户端的消费速度跟不上服务端的发送速度，未处理的消息会越来越多，这部分消息就被称为堆积消息。消息没有被及时消费就会产生消息堆积，从而会造成消息消费延迟。 如果您想要在消费组的消息堆积数超过阈值时，通过短信/邮件及时收到通知信息，
Boolean 是否使用客户端默认设置。 是，表示对全部客户端限流。此时不能设置客户端ID。 否，表示对特定客户端限流。此时需要设置客户端ID。 响应参数 状态码：200 表3 响应Body参数 参数 参数类型 描述 job_id String 删除流控配置的任务ID 请求示例 删除用户/客户端流控配置。
是否必选 参数类型 描述 user 否 String 用户名。 不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。 client 否 String 客户端ID。 不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。 user-default 否 Boolean 是否使用用户默认设置。
objects 客户端流控配置列表。 count Integer 用户/客户端流控配置数目。 表4 Quota 参数 参数类型 描述 user String 用户名。 不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。 client String 客户端ID。 不对全部
为什么删除消费组不生效？ 可能原因：您开启了自动创建消费组功能，且您的业务正在连接该消费组消费消息。所以，如果没有停止您的业务，删除了消费组后，消费消息时还是会自动创建该消费组。 解决办法：关闭自动创建消费组功能，即在Kafka控制台的“配置参数”页面，把“auto.create
创建一台与Kafka实例相同VPC和相同安全组的Windows服务器，详细步骤请参考购买并登录Windows弹性云服务器。 如果是已经开启了公网访问，该步骤为可选，在本地浏览器中即可访问，不需要单独的Windows弹性云服务器。 在实例详情信息页面，获取Kafka Manager地址。 未开启公网访问时，Kafka
下文以topic-logstash为例介绍。 Kafka实例未开启公网访问、已开启SASL认证时，获取表3所示信息。 表3 Kafka实例信息（未开启公网访问、已开启SASL认证） 参数名 获取途径 内网连接地址 在Kafka实例详情页的“连接信息”区域，获取“内网连接地址”。 开启的SASL认证机制 在Kafk
在。 根因描述 实例开启了自动创建Topic功能，且有消费者正在连接该Topic。如果没有停止业务，删除Topic后，还会有消息生产行为，并自动创建Topic。 问题解决措施 关闭Kafka自动创建Topic功能，才可以正常删除Topic。关闭方法请参考配置Kafka自动创建Topic。
统计维度 设置带宽使用量的统计维度。 用户/客户端：统计用户/客户端的带宽使用量。 Topic：统计Topic的带宽使用量。 图1 查询带宽使用量的参数 单击“查询”，查看每个代理上用户/客户端/Topic的带宽使用量。 父主题： 配置流控
是否必选 参数类型 描述 user 否 String 用户名。 不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。 client 否 String 客户端ID。 不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。 user-default 否 Boolean 是否使用用户默认设置。
查看监控指标与配置告警 查看Kafka监控数据 Kafka支持的监控指标 配置Kafka监控告警
- [root@ecs-kafka bin]# 已开启密文接入的Kafka实例，通过以下步骤查询消费进度。 （可选）修改客户端配置文件。 在Kafka控制台的“基本信息 > 连接信息”中查看Kafka安全协议，两种安全协议对应的配置文件设置有所不同，请根据实际情况配置。 SASL_
Topic详情 修改Kafka Topic配置 修改Kafka Topic分区数 修改Kafka Topic副本数 导出Kafka Topic列表 修改Kafka分区平衡 配置Kafka自动创建Topic 删除Kafka Topic 父主题： 配置Topic
broker_connections 连接数 统计Kafka节点当前所有TCP连接数量。 单位：Count 2020年4月及以后购买的实例，支持此监控项。 0~65535 Kafka实例节点 1分钟 broker_cpu_usage CPU使用率 统计Kafka节点虚拟机的CPU使用率。 单位：%
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
