lechindianer/kafkaex-lag-exporter
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix type mismatch

Browse Source
This commit is contained in:
Pascal Schmid
2024-03-27 22:26:02 +01:00
parent 3d835480d1
commit f09ad58fb5
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
lib/kafkaex_lag_exporter/metrics.ex
View File

@@ -38,7 +38,7 @@ defmodule KafkaexLagExporter.Metrics do
@doc false @doc false
def group_sum_lag({host, _port}, consumer_lags) do def group_sum_lag({host, _port}, consumer_lags) do
Enum.each(consumer_lags, fn [group_name, lag] -> Enum.each(consumer_lags, fn {group_name, lag} ->
:telemetry.execute( :telemetry.execute(
[@kafka_event, :consumergroup, :group, :topic, :sum, :lag], [@kafka_event, :consumergroup, :group, :topic, :sum, :lag],
%{ %{
@@ -55,7 +55,7 @@ defmodule KafkaexLagExporter.Metrics do
@doc false @doc false
def group_lag_per_partition({host, _port}, consumer_lags) do def group_lag_per_partition({host, _port}, consumer_lags) do
Enum.each(consumer_lags, fn [group_name, lags] -> Enum.each(consumer_lags, fn {group_name, lags} ->
Enum.each(lags, fn {partition, lag} -> Enum.each(lags, fn {partition, lag} ->
:telemetry.execute( :telemetry.execute(
[@kafka_event, :consumergroup, :group, :lag], [@kafka_event, :consumergroup, :group, :lag],