flink1.20.2环境部署和实验-1
flink环境部署和实验
- 1.环境准备
-
- 1.1.kafka（非容器化）
-
- 1.1.1.jdk 17
- 1.1.2.设置.bash_profile
- 1.1.3.安装配置kafka
- 1.1.4.启动kafka
- 1.1.5.测试
- 1.2.kafka(容器化安装-推荐)
- 1.2.flink
-
- 1.2.1.jdk11安装
- 1.2.2.设置.bash_profile
- 1.2.3.配置ssh免密登录
- 1.2.4.flink
- 1.2.5.启动
- 1.2.5.访问管理台
- 2.实验
说明：
flink 1.20.2，需要使用jdk11，部署成standalone模式。
kafka ，需要使用jdk17
1.环境准备
1.1.kafka（非容器化）
1.1.1.jdk 17
将kafka安装在kafka操作系统用户下，HOME=/home/kafka
tar zxvf jdk-17.0.14_linux-x64_bin.tar.gz
ln -s jdk-17.0.14_linux-x64_bin jdk17
1.1.2.设置.bash_profile
export JAVA_HOME=/home/kafka/jdk17
export PATH=$JAVA_HOME/bin:$PATH
1.1.3.安装配置kafka
# 解压kafka
tar -xzf kafka_2.13-4.1.0.tgz
ln -s kafka_2.13-4.1.0 kafkacd kafka#-- 修改服务器IP
vi config/server.properties
# 修改localhost为具体的IP# 生成集群UUID$ KAFKA_CLUSTER_ID="$(bin/kafka-storage.sh random-uuid)"<