Hi Luke, Yeah, I looked at withTrustSelfSignedCerts options, but after looking at elasticsearchIO code, it seems that flag comes into effect only when "withKeystorePath" is provided. I don't think that can be any gcs path. I believe that is a path in worker VM and for that I will have to use JvmInitliazer to add a custom keystore.
Regarding: "Feel free to create a PR and add any options following the pattern that is already there in the code" . What are the guidelines for adding code and creating PR for beam codebase. Can you point me to the relevant document? Thanks and regards Mohil On Fri, Sep 25, 2020 at 8:45 AM Luke Cwik <[email protected]> wrote: > It doesn't look like it based upon the javadoc: > > https://beam.apache.org/releases/javadoc/2.23.0/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.ConnectionConfiguration.html > > You can allow self signed certs which might be enough for you though: > > https://beam.apache.org/releases/javadoc/2.23.0/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.ConnectionConfiguration.html#withTrustSelfSignedCerts-boolean- > > Feel free to create a PR and add any options following the pattern that is > already there in the code. > > On Thu, Sep 24, 2020 at 8:36 PM Mohil Khare <[email protected]> wrote: > >> Hello team and elasticSearchIO users, >> >> I am using beam java sdk 2.23.0 with elastic search as one of the sinks. >> >> Is there any way to turn off ssl check i.e. set cert verify false for >> https connection with elasticsearchIO ? I know using regular clients, you >> can do that. But can we achieve the same using elasticsearchIO ? >> >> Thanks and regards >> Mohil >> >
