认证方式

集群默认为Flink启用 Kerberos 安全认证策略并分发keytab安全凭据。Flink 的 Kerberos 能力可用于访问 HDFS、Kafka等其他集群服务。
针对Flink 1.18及以下版本，Flink服务部署后您可查看“${FLINK_HOME}/conf/flink-conf.yaml”配置文件中的默认添加的keytab路径以及用户名。

针对Flink 1.20及以上版本，Flink服务部署后您可查看“${FLINK_HOME}/conf/config.yaml”配置文件中的默认添加的keytab路径以及用户名。

security.kerberos.login.keytab: <user.keytab文件路径>
security.kerberos.login.principal: <用户名>

例如：

security.kerberos.login.keytab: /client/flink/conf/test.keytab
security.kerberos.login.principal: test

您可通过执行如下命令认证已创建的用户。

例如：

kinit -kt /client/flink/conf/test.keytab test

权限说明

使用 Flink 前，请确保kerberos用户至少具备以下权限：

• 提交、停止、取消和查看 Flink 作业的权限。

• 访问作业读取的数据源和写入的数据目标的权限。

• 访问 Checkpoint、Savepoint、日志目录和依赖 JAR 存放路径的权限。