Initial OAuth

[padraicbc]

Description:

Adds OAuth support to Kafka/Sarama

Link to tracking Issue:

Testing:

Documentation:

To use it in the config under exporters:

  kafka/dev-oauth:
      topic: metrics
      brokers:
        - XXXX:9095
      auth:
        oauth2: 
          client_id: XXXXX
          client_secret: XXXXXXXXXXXXXXX
          token_url:  "https://XXXX/v1/token"
          scopes: ["some-scope"]

[atoulme]

Please add tests - any chance to reuse the configauth package to set up this oauth client provider?

[padraicbc]

Please add tests - any chance to reuse the configauth package to set up this oauth client provider?

No worries. I will add some tests.

I did actually use oauth2client from there initially but it threw an error around expecting a map and getting a string whan I passed the oauth2client extenstion in under the auth key? I saw nothing was used in the Sarama config so realised it wasn't supported anyway, so I added this PR. I presume we would need to restructure how things are done to integrate the extension?

[MovieStoreGuy]

Please add tests - any chance to reuse the configauth package to set up this oauth client provider?

No worries. I will add some tests.

I did actually use oauth2client from there initially but it threw an error around expecting a map and getting a string whan I passed the oauth2client extenstion in under the auth key? I saw nothing was used in the Sarama config so realised it wasn't supported anyway, so I added this PR. I presume we would need to restructure how things are done to integrate the extension?

Yeah, for the extension to work we would need to provide a means to wrap the auth provider and then make sarama happy to run it.

[github-actions]

This PR was marked stale due to lack of activity. It will be closed in 14 days.

[github-actions]

Closed as inactive. Feel free to reopen if this PR is still being worked on.