Linux环境里实现FLink项目的Zookeeper与Kafka启动

Posted 桃浪十七丶

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Linux环境里实现FLink项目的Zookeeper与Kafka启动相关的知识,希望对你有一定的参考价值。

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

看到>这个箭头,就是成功了

以上是关于Linux环境里实现FLink项目的Zookeeper与Kafka启动的主要内容,如果未能解决你的问题,请参考以下文章

Linux环境里实现FLink项目的Zookeeper与Kafka启动

Linux环境里实现FLink项目的Zookeeper与Kafka启动

zookeeper环境的搭建

Kafka集群搭建(亲测可用)

Zookeep 分布式锁

Dubblo +zookeep+sprinboot注册发现 来源与狂神