1.配置Flink遇到的坑
启动./start-cluster.sh后提示Permission denied，用sudo会提示Please specify JAVA_HOME. Either in Flink config ./conf/flink-conf.yaml or as system-wide JAVA_HOME.
在flink-conf.yaml里找到关于java的部分，添加上env.java.home: 自己电脑配置的JAVA_HOME,要写绝对路径
2.kafka
启动kafka
启动kafka的一个topic
要先打开zookeeper的zkCli.sh
然后在kafka的bin里运行
./kafka-server-start.sh ../config/server.properties
，顺便jps以下看看有无kafka和zk，有的话就可以创建topic了
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic pk10
牛批
kafka-console-producer.sh --broker-list localhost:9092 --topic pk10
看到>这个箭头，就是成功了
