diff --git a/kafka/service.go b/kafka/service.go index 3fea151..64a2ebf 100644 --- a/kafka/service.go +++ b/kafka/service.go @@ -57,7 +57,7 @@ func (s *Service) CreateAndTestClient(ctx context.Context, l *zap.Logger, opts [ // testConnection tries to fetch Broker metadata and prints some information if connection succeeds. An error will be // returned if connecting fails. func (s *Service) testConnection(client *kgo.Client, ctx context.Context) error { - s.logger.Info("connecting to Kafka seed brokers, trying to fetch cluster metadata", + s.logger.Debug("connecting to Kafka seed brokers, trying to fetch cluster metadata", zap.String("seed_brokers", strings.Join(s.cfg.Brokers, ","))) req := kmsg.MetadataRequest{