1、kafka插件默認要開啟kerberos,否則會報空指針錯誤
捕獲.PNG
2、kafka插件集成后,因為kafka啟動腳本必須指定參數(shù):
nohup bin/kafka-server-start.sh config/server.properties &
這將導致無法加載config目錄下ranger插件的配置文件
需要在環(huán)境變量中配置kafka的cinfig目錄:export CLASSPATH=.:JAVA_HOME/lib/dt.jar:JAVA_HOME/lib/tools.jar:$KAFKA_HOME/config
3、在不開啟kerberos的條件下,kafka無法實現(xiàn)對具體用戶的權(quán)限控制,因為任何用戶發(fā)起produce數(shù)據(jù)到topic上,kafka都會默認為是ANONYMOUS用戶
4、kafka插件集成的配置項:
在kafka的server.properties文件最下面添加如下內(nèi)容
authorizer.class.name=org.apache.ranger.authorization.kafka.authorizer.RangerKafkaAuthorizer