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 <m...@trifork.com> wrote: > 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-connector-opensearch). > > It looks like the connector only supports basic auth (user/pass) at the > moment, and doesn't have an option for manually setting custom headers > either. Is this correct? > > Is there any work in progress towards making this possible? > > We are willing to help contribute to code/discussions if necessary to get > this implemented somehow. > > Regards, > Michael > > -- > Michael Hempel-Jørgensen > Software Pilot > www.trifork.com > > >