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 [cid:989723fe-9102-42cb-b034-267b79b2ca29]
