diff --git a/clients/src/main/java/org/apache/kafka/common/config/SslClientAuth.java b/clients/src/main/java/org/apache/kafka/common/config/SslClientAuth.java index c9552b7c44da8..9667db8ee28ad 100644 --- a/clients/src/main/java/org/apache/kafka/common/config/SslClientAuth.java +++ b/clients/src/main/java/org/apache/kafka/common/config/SslClientAuth.java @@ -32,7 +32,7 @@ public enum SslClientAuth { public static SslClientAuth forConfig(String key) { if (key == null) { - return SslClientAuth.NONE; + return null; } String upperCaseKey = key.toUpperCase(Locale.ROOT); for (SslClientAuth auth : VALUES) { @@ -40,7 +40,7 @@ public static SslClientAuth forConfig(String key) { return auth; } } - return null; + return SslClientAuth.NONE; } @Override