Use PKI for connecting to Elasticsearch cluster using elastic6 sink connector

[Dalmako]

Issue Guidelines

Please review these questions before submitting any issue?

What version of the Stream Reactor are you reporting this issue for?

Are you running the correct version of Kafka/Confluent for the Stream reactor release?

Do you have a supported version of the data source/sink .i.e Cassandra 3.0.9?

Have you read the docs?

What is the expected behaviour?

What was observed?

What is your Connect cluster configuration (connect-avro-distributed.properties)?

What is your connector properties configuration (my-connector.properties)?

Please provide full log files (redact and sensitive information)

[Dalmako]

Hello,

We have a secured elasticsearch cluster using PKI mode, and we want to connect to the cluster using an elastic Sink connector.
We are trying to use the "com.datamountaineer.streamreactor.connect.elastic6.ElasticSinkConnector", but we don't really know how we should configure the connector to use PKI mode against the cluster.

I didn't find any specific documentation about it.
Could you help us with this, or let us know if this is currently supported by any elastic Sink connector type?

Best Regards

[davidsloan]

PKI is an advanced use case that we haven't implemented in the connector. I don't think it's likely we'll be able to implement this in the near future, but we do accept code contributions if you are interested in building this feature yourself.