nifi 访问Kerberos的kafka集群

nifi 访问Kerberos的集群
/data12/nifi/nifi-1.28.1/conf/nifi.properties
nifi.security.user.kerberos.enabled=true
nifi.kerberos.krb5.file=/etc/krb5.conf
nifi.kerberos.service.principal=
nifi.kerberos.service.keytab.location=
nifi.kerberos.spnego.principal=HTTP/_HOST@GOERTEK.COM
nifi.kerberos.spnego.keytab.location=/etc/security/keytabs/spnego.service.keytab
重启服务：
/data12/nifi/nifi-1.28.1/bin/nifi.sh status # 查看状态
/data12/nifi/nifi-1.28.1/bin/nifi.sh restart # 重启（需滚动执行）

样例：
1、添加读取MySQL数据的处理器-ExecuteSql
首先添加ExecuteSql处理器，用来从MySQL中读取数据
接着右键configuration进行配置：configure
添加一个数据源：dbcpconnectionpool
启用连接池
录入查询得sql

2、添加数据转换处理器-ConvertRecord
设置Record Reader和Record Writer:
注意需要启用二者

3、配置Kafka生产者处理器
使用PublishKafka处理器
拖拽PublishKafka_2_6或更高版本处理器至画布。