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)
