如何解决NiFi中的Kafka oauth 2.0
我发现了如何对Kafka执行OAuth 2.0。
我可以配置kafka并创建安全主题。在教程中考虑了控制台的使用者和生产者：
security.protocol=SASL_PLAINTEXT
sasl.mechanism=OAUTHBEARER
sasl.login.callback.handler.class=com.oauth2.security.oauthbearer.OAuthAuthenticateLoginCallbackHandler
sasl.jaas.config=org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required OAUTH_LOGIN_SERVER=<OAuth-server-url> OAUTH_LOGIN_ENDPOINT='/oauth2/default/v1/token' OAUTH_LOGIN_GRANT_TYPE=client_credentials OAUTH_LOGIN_ScopE=kafka OAUTH_AUTHORIZATION='Basic <encoded-producer-clientId:clientsecret>' OAUTH_INTROSPECT_SERVER=<OAuth-server-url> OAUTH_INTROSPECT_ENDPOINT='/oauth2/default/v1/introspect' OAUTH_INTROSPECT_AUTHORIZATION='Basic <encoded-producer-clientId:clientsecret>';
sasl-oauth2-producerapp-config.properties：
<%@ Register Assembly="Ext.Net" Namespace="Ext.Net" TagPrefix="ext" %>对于消费者来说是相似的
是否可以在NiFi中将此功能添加到Kafka生产者和消费者处理器中？我找不到在哪里可以输入sasl-oauth2-producerapp-config.properties的路径，或者该属性直接指向处理器参数
解决方法
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
