Added direct support for oauth2 tokens in kafka using franz-lib
Initially I thought it was not supported, but I talked to the author of the library a while ago and got it confirmed: https://github.com/twmb/franz-go/issues/482
I then implemented the setup in this project: https://github.com/redpanda-data/console/issues/699
And would like to do the same here.
I prefer not to use the external cache mechanism for oauth2 tokens, also from a security standpoint of having the token stored several places.
- [x] Test input
- [x] Test output
I am not sure I understand the framework completely yet. Can we store the token between requests without getting a new token on each message-in-flight?
I am not sure I understand the framework completely yet. Can we store the token between requests without getting a new token on each message-in-flight?
I have tested some more and it seems to work. When running parallism, it will naturally get more tokens