Add support for OAuthbearer auth mechanism
cbcoutinho opened this issue · 2 comments
cbcoutinho commented
Checklist
- I have included information about relevant versions
- I have verified that the issue persists when using the
master
branch of Faust.
Steps to reproduce
OAuth 2.0 support would allow faust streaming apps to be used in Confluent Cloud clusters configured with custom identity pools.
For comparison, the Confluent python library supports OAuth 2 by providing a callback to the consumer/producer __init__
.
Expected behavior
It would be great to be able to utilize Faust with clusters that require integration with external identity providers.
wbarnha commented
We use aiokafka
but it seems to be possible to use OAuth from the existing issue in aio-libs/aiokafka#691.