aio-libs / aiokafka

asyncio client for kafka
http://aiokafka.readthedocs.io/
Apache License 2.0
1.08k stars 224 forks source link

[QUESTION] Is there support to refresh OAuth tokens automatically based on token expiration duration? #1015

Open sara-han opened 2 weeks ago

sara-han commented 2 weeks ago

Hi,

We're using OAUTHBEARER sasl_mechanism to connect to AWS MSK with MSKAuthTokenProvider generated tokens. The tokens have an expiration duration. Is there any way to make the Kafka clients refresh the connections before the token expires? Does the client support KIP-368?

Right now, we observe that a connection is established. Later, there will be a Kafka connection failure because the connection is closed by the broker.