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

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new 96255fd  Included securityProtocol=SSL parameter (#2563)
96255fd is described below

commit 96255fd09d5590651fb94f59690fe5afe14b0c88
Author: Simon Green <[email protected]>
AuthorDate: Fri Oct 12 07:28:24 2018 -0400

    Included securityProtocol=SSL parameter (#2563)
    
    Included &securityProtocol=SSL for SSL configuration, as required by Kafka 
1.0.  SSL configuration does not work unless this param is explicitly set
---
 components/camel-kafka/src/main/docs/kafka-component.adoc | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/components/camel-kafka/src/main/docs/kafka-component.adoc 
b/components/camel-kafka/src/main/docs/kafka-component.adoc
index 912f3fe..7be649e 100644
--- a/components/camel-kafka/src/main/docs/kafka-component.adoc
+++ b/components/camel-kafka/src/main/docs/kafka-component.adoc
@@ -411,7 +411,8 @@ from("kafka:" + TOPIC + "?brokers=localhost:{{kafkaPort}}" +
              "&groupId=A" +
              "&sslKeystoreLocation=/path/to/keystore.jks" +
              "&sslKeystorePassword=changeit" +
-             "&sslKeyPassword=changeit")
+             "&sslKeyPassword=changeit" +
+             "&securityProtocol=SSL")
         .to("mock:result");
 ----
 
@@ -442,7 +443,9 @@ camelContext.addRoutes(new RouteBuilder() {
                      // Setup the topic and broker address
                      "&groupId=A" +
                      // The consumer processor group ID
-                     "&sslContextParameters=#ssl")
+                     "&sslContextParameters=#ssl" +
+                     // The security protocol
+                     "&securityProtocol=SSL)
                      // Reference the SSL configuration
                 .to("mock:result");
     }

Reply via email to