1、kafka插件默认要开启kerberos,否则会报空指针错误
2、kafka插件集成后,因为kafka启动脚本必须指定参数:
nohup bin/kafka-server-start.sh config/server.properties &
这将导致无法加载config目录下ranger插件的配置文件
需要在环境变量中配置kafka的cinfig目录:export CLASSPATH=.:JAVA_HOME/lib/dt.jar:JAVA_HOME/lib/tools.jar:$KAFKA_HOME/config
3、在不开启kerberos的条件下,kafka无法实现对具体用户的权限控制,因为任何用户发起produce数据到topic上,kafka都会默认为是ANONYMOUS用户
4、kafka插件集成的配置项:
在kafka的server.properties文件最下面添加如下内容
authorizer.class.name=org.apache.ranger.authorization.kafka.authorizer.RangerKafkaAuthorizer