2.2. 为 Kafka 客户端授予 OAuth 密码
现在,您可以将 Kafka 客户端配置为使用 OAuth 密码授权机制与 Kafka 代理交互。
密码授予机制属性
security.protocol=SASL_SSL
sasl.mechanism=OAUTHBEARER
sasl.jaas.config=org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required \
oauth.token.endpoint.uri="<token_endpoint_url>" \
oauth.client.id="<client_id>" \
oauth.client.secret="<client_secret>" \
oauth.password.grant.username="<username>" \
oauth.password.grant.password="<password>" \
oauth.scope="<scope>" \
oauth.audience="<audience>" ;
# ...