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");
}