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启动相关推荐

SSH框架,Linux环境里项目问题解决: Could not roll back Hibernate transaction;TransactionException: JDBC rollback
介绍: ssh开发的项目,放到Linux上如果8个小时不进行任何操作,则会出现以下问题: 解决办法: 1.如果mysql是5以下的可以在hibernate.cfg.xml配置--aut ...
github上的linux项目,克隆GitHub上项目的非Master分支
问题来了项目现在Github上有两个分支,分别是 master 和 gh-pages,其中master没什么东西,代码都在gh-pages分支上,而我现在想要克隆gh-pages分支上的东西,咋办呢 ...
一篇关于Maven项目的jar包Shell启动脚本
使用Maven作为项目jar包依赖的管理,常常会遇到命令行启动,笔者也是哥菜鸟,在做微服务,以及服务器端开发的过程中,常常会遇到项目的启动需要使用main方法,笔者潜心的研究了很多博客,发现大多写的都 ...
【个人总结】基于项目的AI Studio平台下Linux深度学习环境配置心得
更新一下:现在AI Studio应该已经不能用其他深度学习框架了,用一会儿就会中断前言 PS:本部分主要是对本周工作的总结,标题对应的内容可以跳过本部分上周主要的工作是研究了一下项目utils文件 ...
【原】Jenkins持续集成环境搭建之创建java项目的job【centos6.5 java maven git 项目】...
一.构建一个maven项目在jenkins主页上,左侧,选择"新建",然后填写项目名称,选择"构建一个maven项目" 二.Git配置保存之后,进入详细配置 ...
linux efi启动,在linux环境中利用efibootmgr管理efi启动项
UEFI用来替代传统BIOS引导操作系统,学会修改UEFI启动项也变得十分重要,UEFI全称为:"统一的可扩展固件接口"(Unified Extensible Firmware I ...
linux下环境变量重复,如何清除linux环境变量PATH中的重复项？
如何清除linux环境变量PATH中的重复项? 來源:互聯網 2010-05-26 18:34:31 評論分類: 電腦/網絡 >> 操作系統/系統故障問題描述: 操作系统:linu ...
linux环境下zookeeper部署
2019独角兽企业重金招聘Python工程师标准>>> 下载zookeeper zookeeper下载地址(http://apache.fayea.com/zookeeper/zoo ...
zookeeper 单机和集群搭建(windows环境+linux环境)
文章目录一.单机操作 1. 下载 2. 解压 3. 修改配置文件 4. 启动二.集群操作 2.1. zoo.cfg添加集群配置 2.2. 在3台zk数据目录下面创建myid文件 2.3. 分别启动 ...

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

Linux环境里实现FLink项目的Zookeeper与Kafka启动相关推荐

最新文章

热门文章