配置java环境
因为kafka 是基于java 环境的,所以要先配置java
进入到home路径下,创建app文件夹,把jdk解压到这个目录
创建java的环境变量 ,linux 创建环境变量就是 编辑 /etc/profile 文件,然后source /etc/profile 使它生效
JAVA_HOME=/home/xxx/app/jdk1.8.0_151
JRE_HOME=/home/xxx/app/jdk1.8.0_151/jre
CLASS_PATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib
PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin
export JAVA_HOME JRE_HOME CLASS_PATH PATH
- 验证java环境是否配置完成,bash中输入java 有反应就可以了。
配置kafka
要启动kafka必须先启动zookeeper,zookeeper 是kafka 的分布式协调工具,来保证kafka 多节点运行稳定的。现在kafka 安装包里自带了zookeeper 执行文件。
- 先下载kafka 执行文件 https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/
- 把kafka 解压到app文件夹里
- cd到kafka目录里面 运行
./bin/zookeeper-server-start.sh config/zookeeper.properties
启动zookeeper - 再开一个窗口运行
./bin/kafka-server-start.sh config/server.properties
启动kafka
小结
kafka 全是用的默认配置文件。只需要载相关语言的sdk 然后 连接 localhost:9092
就好了