c/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSink.java
MHJ>
MHJ> From: Andriy Redko
MHJ> Sent: Tuesday, 18 April 2023 4:16:45 PM
MHJ> To: Martijn Visser; Michael Hempel Jørgensen
MHJ> Cc: user@flink.apache.org
MHJ> Subject: Re: Op
connector and oauth
Hi Michael,
Indeed the Opensearch REST client supports only basic auth at the moment. I
don't know which sink are you using, but the
streaming/connectors/opensearch/OpensearchSink provides the capability to
configure the underlying client using
RestClientFactory [1] s
Hi Michael,
Indeed the Opensearch REST client supports only basic auth at the moment. I
don't know which sink are you using, but the
streaming/connectors/opensearch/OpensearchSink provides the capability to
configure the underlying client using
RestClientFactory [1] so you could add the reques
Hi Michael,
I'm looping in Andrey since he has worked a lot on the Opensearch
connector. A contribution is very welcome in case this can be improved.
Best regards,
Martijn
On Tue, Apr 18, 2023 at 8:45 AM Michael Hempel Jørgensen
wrote:
> Hi,
>
> we need to use OAuth2 (Client Credentials Flo
Hi,
we need to use OAuth2 (Client Credentials Flow) in Flink to authenticate and
authorise against different services, initially Kafka and Opensearch. We have
it working with Kafka using however it doesn't seem to be possible with the
Opensearch Flink Connector
(https://github.com/apache/flink
