文章目录 01引言 02流程分析 03核心配置 3.1hadoop环境配置 3.2flink-conf.yaml 3.3连接器相关的配置 04文末 01引言 博主前面写过一篇文章（《flinkkerberos认证源码剖析》）主要是讲解了flinkkerberos的认证原理以及代码流程分析。 可以知道，flink只要做一次kerberos的用户认证，就完美了对接connector所有涉及kerberos认证的组件，如：kafka、zookeeper、hadoop组件等。 本文以提交作业至一个有认证的hadoop环境，执行有认证的kafka实时同步到mysql的flink作业为例...