一. 环境1. 可用的k8s集群2. 宿主机有flink在这里插入图片描述3. 创建k8s命名空间# 创建namespacekubectl create namespace flink-session-test# 新建一个serviceaccount, 提交flinkkubectl create serviceaccount flink -n flink-session-test# 绑定kubec

工具类public class KafkaUtils {/*** 功能描述: <br>* 〈自定义build,生产kafkaSource〉* @Param: [env, topic, groupId, offsets]* @Return: org.apache.flink.streaming.api.datastream.DataStreamSource<java.lang.St