更新时间:2022-12-14 GMT+08:00

使用KafkaUI管理Topic

操作场景

通过KafkaUI查看Topic详情、修改Topic Configs、增加Topic分区个数、删除Topic,并可实时查看不同时段的生产数据条数。

  • 安全模式下,KafkaUI对查看Topic详情操作不作鉴权处理,即任何用户都可以查询Topic信息;对于修改Topic Configs、增加Topic分区个数、删除Topic场景,需保证KafkaUI登录用户属于“kafkaadmin”用户组或者单独给用户授予对应操作权限,否则将会鉴权失败。
  • 非安全模式下,KafkUI对所有操作不作鉴权处理。

查看Topic详情

  1. 进入KafkaUI,请参考使用Flink WebUI
  2. 单击“Topics”,进入Topic管理页面。
  3. 在“Topic List”栏可查看当前集群已创建的Topic的名称、状态、分区数量、创建时间和副本个数等信息。

  4. 单击Topic名称可进入Topic详情页面。在该页面可查看Topic与分区的详细信息。

  5. 在“Producer Message”栏可根据业务需求选择“Day”、“Week”、“Month”不同时段查看此Topic生产数据条数。

修改Topic配置

  1. 进入KafkaUI,请参考访问KafkaUI
  2. 单击“Topics”,进入Topic管理页面。
  1. 在待修改项的“Operation”列单击“Action > Config”,弹出的页面中可修改Topic的“Key”和“Value”值,如需要添加多条,可单击添加。
  2. 单击“OK”完成修改。

搜索Topic

  1. 进入KafkaUI,请参考访问KafkaUI
  2. 单击“Topics”,进入Topic管理页面。
  3. 在页面右上角,用户可以输入Topic名称搜索查看该Topic信息。

增加分区

  1. 进入KafkaUI,请参考访问KafkaUI
  2. 单击“Topics”,进入Topic管理页面。
  3. 在待修改项的“Operation”列单击“Action > Alter”,弹出的页面中修改Topic分区。

    目前集群只支持增加分区操作,即修改的分区个数要大于原设置的分区个数。

  4. 单击“OK”完成修改。

删除Topic

  1. 进入KafkaUI,请参考访问KafkaUI
  2. 单击“Topics”,进入Topic管理页面。
  3. 在待修改项的“Operation”列单击“Action > Delete”。
  4. 在弹出的确认信息页面中单击“OK”即可完成删除。

    系统默认内置的Topic不支持删除操作。

查看生产数据条数

  1. 进入KafkaUI,请参考访问KafkaUI
  2. 单击“Topics”,进入Topic管理页面。
  3. 在“Producer Message”栏可选择“Day”、“Week”、“Month”不同时段查看当前集群所有集群生产数据条数。