connect icon indicating copy to clipboard operation
connect copied to clipboard

Added direct support for oauth2 tokens in kafka using franz-lib

Open cthtrifork opened this issue 1 year ago • 3 comments

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

cthtrifork avatar Feb 29 '24 08:02 cthtrifork

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?

cthtrifork avatar Feb 29 '24 08:02 cthtrifork

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

cthtrifork avatar Mar 03 '24 19:03 cthtrifork