flink写入带kerberos认证的kudu connector

文章结构概述

• • • 前言

      • 一、介绍

      • 二、先来看kudu java api认证kerberos

      • • • 1.首先需要完成kerberos的验证过程（需将对应用户的keytab文件导入本地环境）

      • 2.依赖项配置

      • 3.引入hadoop 的配置文件

      • 4.获取客户端实例

      • 5.实现数据的增删改查操作

      • 三、对flink-kudu connector进行kerberos支持的调整

      • • • 1.首先从github 网站下载相关源代码

      • 2.进行必要的代码修改

      • 四、分享经过修改后的代码内容

前言

经过长时间的网络搜索，发现相关资料极为有限，最终仍需依靠自身力量完成。

一、介绍

Flink官方尚未提供flink-kudu连接器，可采用以下第三方实现，具体信息请参见下方链接：

https://bahir.apache.org/ docs __ /flink/current/flink-streaming-kudu/

然而，该实现目前不兼容Kerberos认证机制，需用户自行对源代码进行修改以满足需求。

二、先来看kudu java