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

Fix credo findings

Browse Source
This commit is contained in:
Pascal Schmid
2022-02-19 14:23:24 +01:00
parent dec7c159f4
commit 36b5f2f2d9
2 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
lib/consumer_offsets_consumer_group.ex
View File

@@ -1,4 +1,9 @@
defmodule ConsumerOffsetsGenConsumer do defmodule ConsumerOffsetsGenConsumer do
@moduledoc """
Genserver implementation to consume new messages on topic '__consumer_offsets'
"""
use KafkaEx.GenConsumer use KafkaEx.GenConsumer
alias KafkaEx.Protocol.Fetch.Message alias KafkaEx.Protocol.Fetch.Message

5
lib/kafkaex_lag_exporter.ex
View File

@@ -1,4 +1,9 @@
defmodule KafkaexLagExporter do defmodule KafkaexLagExporter do
@moduledoc """
Supervisor to start the '__consumer__offsets' watcher child
"""
use Application use Application
def start(_type, _args) do def start(_type, _args) do