Flink 1.10 Kafka 0.10.2
环境配置文件在 src/main/resources/config 目录 application-local.properties 本地环境 application-test.properties 测试环境 application-prod.properties 生成环境
mvn clean package -Pproduct 打生产环境包 mvn clean package -Ptest 打测试环境包 mvn clean package -Plocal 打本地包
-Dmaven.test.skip=true 跳过测试用例
Mac Flink本地安装目录 以及启动脚本 /usr/local/Cellar/apache-flink/1.10.0/libexec/bin/start-cluster.sh
flink run
-c com.yineng.stream.Streaming target/flink-learning-1.0-SNAPSHOT.jar
flink run
-s path
-c com.yineng.stream.Streaming target/flink-learning-1.0-SNAPSHOT.jar \