Topic管理

Topic管理

基础信息

• 创建Topic

  新建Topic时，需要维护Topic名称、分区数、副本数、过期时间、描述信息。

  note

  副本数需要小于等于Brokers数；

  存储时间默认168h（7天），到期后时删除还是压缩，根据kafka配置执行

  

• Topic列表

  列表里会展示集群内已存在的Topic信息和平台新建的Topic，点击进入查看Topic详情。

  

• Topic基本信息&数据曲线

  展示Topic的基础信息和实时指标，指标口径和含义同集群指标。各个指标数据在曲线图中支持查看趋势波动。

  note

  健康分计算逻辑：

  

• Comsumer管理

  列表展示当前Topic下的所有Consumer Group ID，点击ID进入查看消费详情。

  PartitionID：显示这个Topic下有多少个Partition

  Partition Offset：显示每个Partition中最新的offset

  Consumer Offset：显示每个Partition被消费到了哪个offset

  Lag：显示每个Partition的消费延迟情况，等于Partition Offset-Consumer Offset

  

• 分区管理

  列表展示当前Topic下的所有Partition ID及其基本信息，参数内容和解释如下表：

  参数值	参数解释
  Partition ID	表示分区标识
  beginningOffsets	表示分区的起始位置。该值不用永远等于0，因为日志清理的动作会清理旧的数据，所以分区的起始位置会自然而然地增加
  endOffsets	表示分区的结束位置
  msgNum	表示分区中未过期的消息条数
  Logsize(MB)	表示历史已经写入该分区的数据量
  Leader	表示该分区的leader broker
  优选副本	表示该分区的候选leader broker
  ISR	表示该分区的副本同步队列

Topic采样

该功能主要通过查看样例数据，帮助用户更直观地理解这个Topic。只需要选择Topic名称、输入采集条数和超时时间即可完成样例数据的采集，也可以通过指定分区和offset位置进行采集。