部署前准备(需要root账号)节点主机名唯一，建议写入/etc/hosts禁止swap分区关闭防火墙root@haishu:/home/haishu# hostnamectl set-hostname k8s-masterroot@haishu:/home/haishu# tail /etc/hosts127.0.1.1haishu-System-Product-Name# The followi

场景：用户请求信息通过kafka到flink计算引擎，flink拿到请求信息后去查询三方数据处理，数据处理完成后把处理结果放回到kafka中。这里三方数据源两种：1.mysql数据源2.http三方接口项目地址：https://github.com/1105748319/flinkDemoTest.git下面直接上代码：主要的类：package com.flink;import org.apach

#flink连接kafka并读取数据前提条件flink版本1.11.2直接上代码import org.apache.flink.api.common.functions.FlatMapFunction;import org.apache.flink.api.common.restartstrategy.RestartStrategies;import org.apache.flink.stream