This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch sandbox/camel-3.x in repository https://gitbox.apache.org/repos/asf/camel.git
commit 9dba9530048587448aa60ae677f7146b92873aa0 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"); }
