From 36b5f2f2d9ee4898a797e1f97a8cb2dfbe6007b4 Mon Sep 17 00:00:00 2001 From: Pascal Schmid Date: Sat, 19 Feb 2022 14:23:24 +0100 Subject: [PATCH] Fix credo findings --- lib/consumer_offsets_consumer_group.ex | 5 +++++ lib/kafkaex_lag_exporter.ex | 5 +++++ 2 files changed, 10 insertions(+) diff --git a/lib/consumer_offsets_consumer_group.ex b/lib/consumer_offsets_consumer_group.ex index 003a9f8..c57f69c 100644 --- a/lib/consumer_offsets_consumer_group.ex +++ b/lib/consumer_offsets_consumer_group.ex @@ -1,4 +1,9 @@ defmodule ConsumerOffsetsGenConsumer do + + @moduledoc """ + Genserver implementation to consume new messages on topic '__consumer_offsets' + """ + use KafkaEx.GenConsumer alias KafkaEx.Protocol.Fetch.Message diff --git a/lib/kafkaex_lag_exporter.ex b/lib/kafkaex_lag_exporter.ex index b2b2d6b..017ad7f 100644 --- a/lib/kafkaex_lag_exporter.ex +++ b/lib/kafkaex_lag_exporter.ex @@ -1,4 +1,9 @@ defmodule KafkaexLagExporter do + + @moduledoc """ + Supervisor to start the '__consumer__offsets' watcher child + """ + use Application def start(_type, _args) do