kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: MINOR: Reduce the log level when the peer isn't authenticated but is using SSL
Date Wed, 07 Sep 2016 02:43:56 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk d2acd676c -> 16469d7f9


MINOR: Reduce the log level when the peer isn't authenticated but is using SSL

The commit here changes the log level of a log message from WARN to DEBUG.
As noted in the mail discussion here https://www.mail-archive.com/devkafka.apache.org/msg56035.html,
in a pretty straightforward/typical and valid setup, the broker logs get
flooded with the following message:

[2016-09-02 08:07:13,773] WARN SSL peer is not authenticated, returning ANONYMOUS instead
(org.apache.kafka.common.network.SslTransportLayer)

Author: Jaikiran Pai <jaikiran.pai@gmail.com>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #1825 from jaikiran/ssl-log-level


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/16469d7f
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/16469d7f
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/16469d7f

Branch: refs/heads/trunk
Commit: 16469d7f94f0a7d82c2a74515ab0903ce6ca9c5e
Parents: d2acd67
Author: Jaikiran Pai <jaikiran.pai@gmail.com>
Authored: Wed Sep 7 02:05:25 2016 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Wed Sep 7 03:42:57 2016 +0100

----------------------------------------------------------------------
 .../java/org/apache/kafka/common/network/SslTransportLayer.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/16469d7f/clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java
b/clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java
index cfd618d..f8926f3 100644
--- a/clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java
+++ b/clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java
@@ -635,7 +635,7 @@ public class SslTransportLayer implements TransportLayer {
         try {
             return sslEngine.getSession().getPeerPrincipal();
         } catch (SSLPeerUnverifiedException se) {
-            log.warn("SSL peer is not authenticated, returning ANONYMOUS instead");
+            log.debug("SSL peer is not authenticated, returning ANONYMOUS instead");
             return KafkaPrincipal.ANONYMOUS;
         }
     }


Mime
View raw message