You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Michael Hempel-Jørgensen (Jira)" <ji...@apache.org> on 2023/04/19 14:25:00 UTC

[jira] [Created] (FLINK-31856) Add support for Opensearch Connector REST client customization

Michael Hempel-Jørgensen created FLINK-31856:
------------------------------------------------

             Summary: Add support for Opensearch Connector REST client customization
                 Key: FLINK-31856
                 URL: https://issues.apache.org/jira/browse/FLINK-31856
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / Opensearch
    Affects Versions: opensearch-1.0.0
            Reporter: Michael Hempel-Jørgensen


It is not currently possible to customise the Opensearch REST client in all of the connectors.

We are currently using the using the OpensearchSink in [connector/opensearch/sink/OpensearchSink.java|https://github.com/apache/flink-connector-opensearch/blob/main/flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSink.java] and need to be able to authenticate/authorise with Opensearch using OAuth2 and therefore need to be able to pass a bearer token to the bulk index calls.

The access token will expire and change during the jobs lifetime it must be possible to handle this, i.e. giving a token at when building the sink is not enough.

For reference see the mailing list discussion: https://lists.apache.org/thread/9rvwhzjwzm6yq9mg481sdxqx9nqr1x5g



--
This message was sent by Atlassian Jira
(v8.20.10#820010)