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