diff --git a/pkg/queue/kafka/kafka.go b/pkg/queue/kafka/kafka.go index 2cb0d50..bdca59c 100644 --- a/pkg/queue/kafka/kafka.go +++ b/pkg/queue/kafka/kafka.go @@ -2,9 +2,10 @@ package kafka import ( "context" - "github.com/bugrakocabay/konsume/pkg/config" "log/slog" + "github.com/bugrakocabay/konsume/pkg/config" + "github.com/segmentio/kafka-go" ) diff --git a/pkg/requester/requester.go b/pkg/requester/requester.go index 8e39964..cc8d30f 100644 --- a/pkg/requester/requester.go +++ b/pkg/requester/requester.go @@ -73,7 +73,7 @@ func (r *Requester) SendRequest(m *config.MetricsConfig, timeout time.Duration) } defer resp.Body.Close() - if m.Enabled { + if m != nil && m.Enabled { metrics.HttpRequestsMade.Inc() if resp.StatusCode >= m.ThresholdStatus { metrics.HttpRequestsFailed.Inc()