Skip to content

Commit

Permalink
fix(metrics): fix jmx rules (#1041)
Browse files Browse the repository at this point in the history
Signed-off-by: Shichao Nie <[email protected]>
  • Loading branch information
SCNieh authored Mar 28, 2024
1 parent ceceb8e commit 1795340
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions core/src/main/resources/jmx/rules/broker.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -252,14 +252,14 @@ rules:
desc: The number of requests waiting in purgatory

# Replica Metrics
- bean: kafka.server:type=ReplicaManager,name=PartitionCount
- bean: kafka.server.streamaspect:type=ElasticReplicaManager,name=PartitionCount
mapping:
Value:
metric: kafka.partition.count
type: gauge
desc: The number of partitions on the broker

- bean: kafka.server:type=ReplicaManager,name=ReassigningPartitions
- bean: kafka.server.streamaspect:type=ElasticReplicaManager,name=ReassigningPartitions
mapping:
Value:
metric: kafka.reassign.partition.count
Expand Down Expand Up @@ -292,7 +292,7 @@ rules:
type: gauge
desc: Log flush time - max

- bean: kafka.log.streamaspect:type=Log,name=LogEndOffset,topic=*,partition=*
- bean: kafka.log:type=Log,name=LogEndOffset,topic=*,partition=*
metricAttribute:
topic: param(topic)
partition: param(partition)
Expand All @@ -302,7 +302,7 @@ rules:
type: gauge
desc: Log end offset for topic-partition

- bean: kafka.log.streamaspect:type=Log,name=Size,topic=*,partition=*
- bean: kafka.log:type=Log,name=Size,topic=*,partition=*
metricAttribute:
topic: param(topic)
partition: param(partition)
Expand Down

0 comments on commit 1795340

Please sign in to comment.