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 <[email protected]> Reviewers: Ismael Juma <[email protected]> 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 <[email protected]> Authored: Wed Sep 7 02:05:25 2016 +0100 Committer: Ismael Juma <[email protected]> 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; } }
