BigQuery to Elasticsearch Self-Managed configuration

Hi All,

Am trying to test out the steps given here:

As per the documentation it says the implementation flow remains the same for "The integration works for all users, regardless of whether you are using the Elastic Stack on Elastic Cloud, Elastic Cloud in the Google Cloud Marketplace, or a self-managed environment."

However when trying to use this dataflow template in big query dataflows it shows that the field Cloud API Key is mandatory. In that case how can we use this dataflow template for Self-Managed Instances with basic auth enabled. If anyone has been able to get this working please help.


This is the API Key, it is not related to Elastic Cloud.

You can create an API Key on self-managed without any problems, just go on Kibana, Stack Management, Security, API Keys.

The guide you shared has a link to the part of the documentation on how you can create an API key.

Fill in the required parameters, including your Cloud ID and Base64-encoded API Key for Elasticsearch. Cloud ID can be found from Elastic Cloud UI as shown below. API Key can be created using the Create API key API.

You just need to create an API Key and use it in that field.


I even tried by creating a trial elastic could id and then applying the bigquery template but I get the following error now.

[RuntimeException: org.apache.beam.sdk.util.UserCodeException: java.lang.IllegalArgumentException: Cannot get Elasticsearch version]

Also is there any option on the big query template to not use API Key and only use the basic auth creds.

What version of Elasticsearch are you using?


Are you using the default distribution?



In this template it has a mandatory parameter for API key. however in the code it looks like its either api key or username/password. Please help on how to process with just using username/password as I cannot use the API key approach.

Out of curiosity, why can you not use the API key approach?

Am using the OSS build which is mapped behind our internal proxy using which we are creating the security layer and currently in our security layer we only support the Basic auth and don't yet have an API key mech implemented. Hence want to see if there is a way to get it working with Basic Auth.

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.