diff --git a/pkg/apiserver/apiserver.go b/pkg/apiserver/apiserver.go
index 0ad229493..bee47e60a 100644
--- a/pkg/apiserver/apiserver.go
+++ b/pkg/apiserver/apiserver.go
@@ -101,7 +101,7 @@ func (s *Server) Run(stopCh <-chan struct{}, wg *sync.WaitGroup) {
 	defer cancel()
 	err := s.http.Shutdown(ctx)
 	if err == context.DeadlineExceeded {
-		s.logger.Warnf("Shutdown timeout exceeded. closing http server")
+		s.logger.Warningf("Shutdown timeout exceeded. closing http server")
 		s.http.Close()
 	} else if err != nil {
 		s.logger.Errorf("Could not shutdown http server: %v", err)
diff --git a/pkg/cluster/cluster.go b/pkg/cluster/cluster.go
index 5fa8d6b36..f48b94fb1 100644
--- a/pkg/cluster/cluster.go
+++ b/pkg/cluster/cluster.go
@@ -294,7 +294,7 @@ func (c *Cluster) compareStatefulSetWith(statefulSet *v1beta1.StatefulSet) *comp
 	}
 	if len(c.Statefulset.Spec.Template.Spec.Containers) == 0 {
 
-		c.logger.Warnf("statefulset %q has no container", util.NameFromMeta(c.Statefulset.ObjectMeta))
+		c.logger.Warningf("statefulset %q has no container", util.NameFromMeta(c.Statefulset.ObjectMeta))
 		return &compareStatefulsetResult{}
 	}
 	// In the comparisons below, the needsReplace and needsRollUpdate flags are never reset, since checks fall through
@@ -479,7 +479,7 @@ func (c *Cluster) Update(newSpec *spec.Postgresql) error {
 	}
 
 	if c.Spec.PgVersion != newSpec.Spec.PgVersion { // PG versions comparison
-		c.logger.Warnf("postgresql version change(%q -> %q) is not allowed",
+		c.logger.Warningf("postgresql version change(%q -> %q) is not allowed",
 			c.Spec.PgVersion, newSpec.Spec.PgVersion)
 		//TODO: rewrite pg version in tpr spec
 	}
diff --git a/pkg/cluster/k8sres.go b/pkg/cluster/k8sres.go
index 0a5b0f99e..fb7377d25 100644
--- a/pkg/cluster/k8sres.go
+++ b/pkg/cluster/k8sres.go
@@ -145,7 +145,7 @@ PATRONI_INITDB_PARAMS:
 					}
 				}
 			default:
-				c.logger.Warnf("unsupported type for initdb configuration item %s: %T", defaultParam, defaultParam)
+				c.logger.Warningf("unsupported type for initdb configuration item %s: %T", defaultParam, defaultParam)
 				continue PATRONI_INITDB_PARAMS
 			}
 		}
diff --git a/pkg/cluster/resources.go b/pkg/cluster/resources.go
index c018f6a02..c72dd386a 100644
--- a/pkg/cluster/resources.go
+++ b/pkg/cluster/resources.go
@@ -199,7 +199,7 @@ func (c *Cluster) replaceStatefulSet(newStatefulSet *v1beta1.StatefulSet) error
 	// check that all the previous replicas were picked up.
 	if newStatefulSet.Spec.Replicas == oldStatefulset.Spec.Replicas &&
 		createdStatefulset.Status.Replicas != oldStatefulset.Status.Replicas {
-		c.logger.Warnf("number of pods for the old and updated Statefulsets is not identical")
+		c.logger.Warningf("number of pods for the old and updated Statefulsets is not identical")
 	}
 
 	c.Statefulset = createdStatefulset
diff --git a/pkg/controller/util.go b/pkg/controller/util.go
index 8c9ec6f64..e9d0c5617 100644
--- a/pkg/controller/util.go
+++ b/pkg/controller/util.go
@@ -99,7 +99,7 @@ Users:
 				case "inrole":
 					t.MemberOf = append(t.MemberOf, s)
 				default:
-					c.logger.Warnf("unknown key %q", p)
+					c.logger.Warningf("unknown key %q", p)
 				}
 			}
 		}