You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ma...@apache.org on 2019/06/23 08:30:48 UTC
[kafka] branch trunk updated: MINOR: Reinstate info-level log for
dynamic update of SSL keystores (#6925)
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 <ra...@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 <ma...@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) {