登录KafkaUI界面
操作场景
MRS集群安装Kafka组件后,通过KafkaUI,用户能够便捷查询集群信息、节点状态、topic分区、数据的生产、消费详情等多维度信息。KafkaUI将Topic创建、删除、配置修改、扩展分区、分区迁移等复杂易出错的管理操作界面化,降低用户使用门槛,提高运维效率。
- 集群内部分区重分布
- 创建、查看和删除Topic
- 对已有Topic进行加分区、配置修改
- 查看Topic生产数据信息
- 查看Broker实例信息
- 查看Consumer Group消费情况
前提条件
已创建具有KafkaUI页面访问权限的用户,如需在页面上进行相关操作,例如创建Topic,需同时授予用户相关权限,请参考Kafka用户权限说明。
对系统的影响
第一次访问Manager和KafkaUI,需要在浏览器中添加站点信任以继续访问KafkaUI。
访问KafkaUI
- 使用具有KafkaUI页面访问权限的用户登录FusionInsight Manager。
登录集群Manager具体操作,请参考访问MRS集群Manager。
- 选择“集群 > 服务 > Kafka”。
- 在“KafkaManager Web UI”右侧,单击URL链接,进入KafkaUI的页面。
- 在KafkaUI页面的菜单栏单击对应页签查看相关信息。 图1 KafkaUI页面
KafkaUI页面介绍
通过KafkaUI,用户能够便捷查询集群信息、节点状态、topic分区、数据的生产、消费详情等多维度信息。
Kafka UI总览
- Cluster Summary
- Cluster Action
在“Cluster Action”中可创建Topic、配置和查看分区迁移。
- Create Topic:单击“Create Topic”进入创建Topic页面,根据页面提示创建Topic。详细操作请参考使用KafkaUI创建Kafka Topic。
- Generate assignment:单击“Generate assignment”进入分区迁移页面,根据页面提示配置分区迁移。详细操作请参考使用KafkaUI迁移分区(MRS 3.5.0之前版本)或使用KafkaUI迁移分区(MRS 3.5.0及之后版本)。
- Current Reassign Status:单击“Current Reassign Status”可以查看当前分区迁移计划的执行情况。 图3 查看分区迁移执行情况
单击“Modify Reassignment Throttle”可以修改分区迁移的限流参数。
单击“Cancel”可以取消当前所有正在执行的分区迁移计划。
- Topic Rank
在“Topic Rank”栏,可查看当前集群Topic日志条数、数据体积大小、数据流入量、数据流出量前十名的Topic。

单击“TopicName”可进入到该Topic的详情页面中。Topics页面的详细介绍请参考Topics。
Topics
单击“Topics”,进入Topic管理页面。
- 在“Topic List”栏可查看当前集群已创建的Topic的名称、状态、分区数量、创建时间和副本个数等信息。 图4 Topic List
单击Topic名称可进入Topic详情页面。在该页面可查看Topic与分区的详细信息。
图5 单击Topic详细信息
在“Producer Message”栏可根据业务需求选择“Day”、“Week”、“Month”不同时段查看此Topic生产数据条数。

- 搜索Topic。
- 修改Topic配置。
在待修改项的“Operation”列选择“Action > Config”,弹出的页面中可修改Topic的“Key”和“Value”值,如需要添加多条,可单击“+”添加。单击“OK”完成修改。
图6 修改Topic配置
- 删除Topic。
在待修改项的“Operation”列选择“Action > Delete”。在弹出的确认信息页面中单击“OK”即可完成删除。
系统默认内置的Topic不支持删除操作。
- 查看生产数据条数。
在“Producer Message”栏可选择“Day”、“Week”、“Month”不同时段查看当前集群所有集群生产数据条数。

Brokers
单击“Brokers”,进入Broker详情页面。
- Broker Summary
在“Broker Summary”中可查看Broker的“Broker ID”、“Host”、“Rack”、“Disk(Used|Total)”和“Memory(Used|Total)”。

- Brokers Metrics
在“Brokers Metrics”中可查看Broker节点数据流量的jmx指标,包括在不同时段的时间窗口内,Broker节点平均每秒流入消息条数, 每秒流入消息字节数, 每秒流出消息字节数,每秒失败的请求数,每秒总的请求数和每秒生产的请求数。

- 在页面右上角,可以根据主机IP地址或者机架配置信息搜索查看该Broker信息。
Consumers
单击“Consumers”,进入消费组详情页面。
可以在该页面中查看当前集群内的所有ConsumerGroups,并可以查看各个ConsumerGroups Coordinator所在节点IP,在页面右上角,用户可以输入ConsumerGroup来搜索指定的ConsumerGroup信息。
- Consumer Summary:在Consumer Summary一栏,可查看当前集群已存在的消费组。 图7 消费组信息
- 单击消费组名称,可查看该消费组所消费过的Topic,消费过的Topic有两种状态:“pending”和“running”,分别表示“曾经消费过但现在未消费”和“现在正在消费”,在弹框右上角,可以输入Topic名来进行过滤。 图8 单击消费组详细信息
- 单击Topic名称,进入Consumer Offsets页面,可查看Topic消费详情。
- 查看消费血缘图。
单击“Consumers”,进入消费组详情页面。在Active Topic处可以查看当前集群所有的消费组,以及各个Consumer Group正在消费的Topic。

MRS集群当前不支持单击消费组名称进行跳转。
Alarms
在菜单栏单击“Alarms”,进入Kafka积压告警页面。
- 创建Kafka消息积压告警。
用户可以在该页面中单击“Create Lag Alarm”,配置需要上报Kafka消息积压告警的规则,当达到配置的积压告警规则要求时,会上报“ALM-38018 Kafka消息积压”告警。详细操作请参考配置Kafka消息积压告警规则。
- 用户可以在“Lag Alarms”列表中查看、修改、删除Kafka消息积压告警的规则信息。
相关文档
- 使用admin用户访问Kafka WebUI报错,处理方法请参见使用admin用户访问组件的WebUI界面报错或部分功能不可用。
- 访问组件WebUI页面报500异常,处理方法请参见访问组件WebUI页面报500异常。

