From 5b0cdeae55f9056922b5c001b94e7494d70a650a Mon Sep 17 00:00:00 2001 From: garnier-quentin Date: Thu, 17 Jan 2019 09:58:06 +0100 Subject: [PATCH] fix kafka jmx plugin --- apps/java/kafka/jmx/mode/globalstats.pm | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/apps/java/kafka/jmx/mode/globalstats.pm b/apps/java/kafka/jmx/mode/globalstats.pm index a3e0f3b7d..db8fa3a67 100644 --- a/apps/java/kafka/jmx/mode/globalstats.pm +++ b/apps/java/kafka/jmx/mode/globalstats.pm @@ -149,10 +149,10 @@ sub manage_selection { partition_count => $result->{'kafka.server:name=PartitionCount,type=ReplicaManager'}->{Value}, leader_count => $result->{'kafka.server:name=LeaderCount,type=ReplicaManager'}->{Value}, active_controller_count => $result->{'kafka.controller:name=ActiveControllerCount,type=KafkaController'}->{Value}, - unclean_leader_elections => $result->{'kafka.controller:name=UncleanLeaderElectionsPerSec,type=ControllerStats'}->{Value}, - traffic_in => $result->{'kafka.server:name=BytesInPerSec,type=BrokerTopicMetrics'}->{Value} * 8, - traffic_out => $result->{'kafka.server:name=BytesOutPerSec,type=BrokerTopicMetrics'}->{Value} * 8, - total_fetch_requests => $result->{'kafka.server:name=TotalFetchRequestsPerSec,type=BrokerTopicMetrics'}->{Value}, + unclean_leader_elections => $result->{'kafka.controller:name=UncleanLeaderElectionsPerSec,type=ControllerStats'}->{Count}, + traffic_in => $result->{'kafka.server:name=BytesInPerSec,type=BrokerTopicMetrics'}->{Count} * 8, + traffic_out => $result->{'kafka.server:name=BytesOutPerSec,type=BrokerTopicMetrics'}->{Count} * 8, + total_fetch_requests => $result->{'kafka.server:name=TotalFetchRequestsPerSec,type=BrokerTopicMetrics'}->{Count}, }; $self->{cache_name} = "kafka_" . $self->{mode} . '_' . md5_hex($options{custom}->get_connection_info()) . '_' .