JKrehling opened a new issue, #1728: URL: https://github.com/apache/camel-kafka-connector/issues/1728
Connector: https://camel.apache.org/camel-kafka-connector/4.10.x/reference/connectors/camel-netty-http-kafka-sink-connector.html "camel.sink.endpoint.keyStoreResource": "file:/tmp/keystore.pkcs12", "camel.sink.endpoint.keyStoreFormat": "PKCS12" "camel.sink.endpoint.ssl": "true", I can set my connectors keyStore Resource and format with the configs but there doesn't seem to be any client keystore sent to my upstream with this setup. Also it appears theres no way to set the password for the keystore either which is odd. If I pass a jks file (which has to have a password) then the status api throws and error about not being able to read a password. If I generate a pkcs12 with no password it throws no errors but my upstream (nginx) throws a 400 because there is no client certificate sent in the request. `cat <<EOF > connector.json { "name": "khttpsink", "config": { "connector.class": "org.apache.camel.kafkaconnector.nettyhttp.CamelNettyhttpSinkConnector", "tasks.max": "5", "topics": "my-topic", "transforms": "headers", "camel.sink.path.protocol": "https", "camel.sink.path.host": "testit.mydomain.com", "camel.sink.path.path": "ktest", "camel.sink.path.port": "8443", "camel.sink.endpoint.ssl": "true", "key.converter.schemas.enable": "false", "value.converter.schemas.enable": "false", "name": "khttpsink", "value.converter": "org.apache.kafka.connect.storage.StringConverter", "key.converter": "org.apache.kafka.connect.storage.StringConverter", "camel.sink.endpoint.throwExceptionOnFailure": "true", "transforms.headers.headers": "CamelHeader.content-type:application/json", "camel.sink.endpoint.keyStoreResource": "file:/tmp/keystore.pkcs12", "camel.sink.endpoint.keyStoreFormat": "PKCS12" } } EOF curl -X DELETE localhost:8083/connectors/khttpsink curl -XPOST -H "Content-Type: application/json" --data @connector.json http://localhost:8083/connectors -kv curl localhost:8083/connectors/khttpsink/status` My sanity check is just running the above in a kafka-connect container. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
