[kafka] branch trunk updated: MINOR: Reinstate info-level log for dynamic update of SSL keystores (#6925)

[manikumar]

This is an automated email from the ASF dual-hosted git repository.

manikumar pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 7cb0a1e  MINOR: Reinstate info-level log for dynamic update of SSL 
keystores (#6925)
7cb0a1e is described below

commit 7cb0a1ef4f4a7c08a56cb9b84d482e60ed5f20f3
Author: Rajini Sivaram <rajinisiva...@googlemail.com>
AuthorDate: Sun Jun 23 09:30:28 2019 +0100

    MINOR: Reinstate info-level log for dynamic update of SSL keystores (#6925)
    
    Reviewers: Manikumar Reddy <manikumar.re...@gmail.com>
---
 .../main/java/org/apache/kafka/common/security/ssl/SslFactory.java | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java 
b/clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java
index 4d94230..c009412 100644
--- a/clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java
+++ b/clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java
@@ -114,7 +114,12 @@ public class SslFactory implements Reconfigurable {
 
     @Override
     public void reconfigure(Map<String, ?> newConfigs) throws KafkaException {
-        this.sslEngineBuilder = createNewSslEngineBuilder(newConfigs);
+        SslEngineBuilder newSslEngineBuilder = 
createNewSslEngineBuilder(newConfigs);
+        if (newSslEngineBuilder != this.sslEngineBuilder) {
+            this.sslEngineBuilder = newSslEngineBuilder;
+            log.info("Created new {} SSL engine builder with keystore {} 
truststore {}", mode,
+                    newSslEngineBuilder.keystore(), 
newSslEngineBuilder.truststore());
+        }
     }
 
     private SslEngineBuilder createNewSslEngineBuilder(Map<String, ?> 
newConfigs) {