...

• add a kafka version metric for per broker: kafka.server:type=KafkaServer/BrokerServer,name=KafkaVersion
  • description: A gauge metric, the value is the current running server version nameconstant `1`.
  • no tags.tags: `Map("version" => VersionInfo.getVersion)`

Proposed Changes

When instantiating kafkaServer/BrokerServer, register `KafkaVersion` gauge metric, whose value is 1, its tag key is "version", its tag value is obtained by `VersionInfo.getVersion`. And remove all related metrics when kafkaServer/BrokerServer shutdown.

...

Test Plan

Rejected Alternatives

Existed metric about version: kafka.server:type=app-info, but its value is not numeric, can not be obtained by prometheus.