Merge branch 'feat/DEX-2306/fix-metrics' into 'master'

[DEX-2306] feat: fix metrics Closes DEX-2306 See merge request nstmrt/rubygems/sbmt-kafka_producer!31
Kuper-Tech · Jun 17, 2024 · bed1f9b · bed1f9b
2 parents 689981e + 44e6d51
commit bed1f9b
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 6 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -13,6 +13,12 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
 
 ### Fixed
 
+## [2.2.2] - 2024-06-15
+
+### Fixed
+
+- Fixed display of metrics `kafka_api_calls`  and `kafka_api_errors`
+
 ## [2.2.1] - 2024-06-07
 
 ### Changed

diff --git a/lib/sbmt/kafka_producer/instrumentation/yabeda_metrics_listener.rb b/lib/sbmt/kafka_producer/instrumentation/yabeda_metrics_listener.rb
@@ -71,15 +71,15 @@ def report_broker_stats(brokers)
             }
 
             Yabeda.kafka_api.calls
-              .increment(broker_tags, by: broker_statistics["tx"])
+              .increment(broker_tags, by: broker_statistics["tx_d"])
             Yabeda.kafka_api.latency
               .measure(broker_tags, broker_statistics["rtt"]["avg"])
             Yabeda.kafka_api.request_size
               .measure(broker_tags, broker_statistics["txbytes"])
             Yabeda.kafka_api.response_size
               .measure(broker_tags, broker_statistics["rxbytes"])
             Yabeda.kafka_api.errors
-              .increment(broker_tags, by: broker_statistics["txerrs"] + broker_statistics["rxerrs"])
+              .increment(broker_tags, by: broker_statistics["txerrs_d"] + broker_statistics["rxerrs_d"])
           end
         end
       end

diff --git a/lib/sbmt/kafka_producer/version.rb b/lib/sbmt/kafka_producer/version.rb
@@ -2,6 +2,6 @@
 
 module Sbmt
   module KafkaProducer
-    VERSION = "2.2.1"
+    VERSION = "2.2.2"
   end
 end
diff --git a/spec/sbmt/kafka_producer/instrumentation/yabeda_metrics_listener_spec.rb b/spec/sbmt/kafka_producer/instrumentation/yabeda_metrics_listener_spec.rb
@@ -12,12 +12,12 @@
             "name" => "kafka:9092/1001",
             "nodeid" => 1001,
             "nodename" => "kafka:9092",
-            "tx" => 7,
+            "tx_d" => 7,
             "txbytes" => 338,
-            "txerrs" => 0,
+            "txerrs_d" => 0,
             "rx" => 7,
             "rxbytes" => 827,
-            "rxerrs" => 0,
+            "rxerrs_d" => 0,
             "rtt" => {
               "avg" => 1984
             }