From 72fe3edca1e08c85d4c9ad8d65cdb0e9634fb9a7 Mon Sep 17 00:00:00 2001 From: Alena Varkockova Date: Mon, 30 May 2022 18:25:45 +0200 Subject: [PATCH] do not log as info from testConnection func --- e2e/service.go | 1 + kafka/service.go | 2 +- minion/service.go | 1 + 3 files changed, 3 insertions(+), 1 deletion(-) diff --git a/e2e/service.go b/e2e/service.go index a711c46..97e0c93 100644 --- a/e2e/service.go +++ b/e2e/service.go @@ -77,6 +77,7 @@ func NewService(ctx context.Context, cfg Config, logger *zap.Logger, kafkaSvc *k if err != nil { return nil, fmt.Errorf("failed to create kafka client for e2e: %w", err) } + logger.Info("successfully connected to kafka cluster") svc := &Service{ config: cfg, diff --git a/kafka/service.go b/kafka/service.go index b2d8d73..3fea151 100644 --- a/kafka/service.go +++ b/kafka/service.go @@ -80,7 +80,7 @@ func (s *Service) testConnection(client *kgo.Client, ctx context.Context) error } versions := kversion.FromApiVersionsResponse(versionsRes) - s.logger.Info("successfully connected to kafka cluster", + s.logger.Debug("successfully connected to kafka cluster", zap.Int("advertised_broker_count", len(res.Brokers)), zap.Int("topic_count", len(res.Topics)), zap.Int32("controller_id", res.ControllerID), diff --git a/minion/service.go b/minion/service.go index 7ed48ac..131ced2 100644 --- a/minion/service.go +++ b/minion/service.go @@ -56,6 +56,7 @@ func NewService(cfg Config, logger *zap.Logger, kafkaSvc *kafka.Service, metrics if err != nil { return nil, fmt.Errorf("failed to create kafka client: %w", err) } + logger.Info("successfully connected to kafka cluster") // Compile regexes. We can ignore the errors because valid compilation has been validated already allowedGroupIDsExpr, _ := compileRegexes(cfg.ConsumerGroups.AllowedGroupIDs)