1.cd /usr/local
2.mkdir java 创建java文件夹
3.把jdk安装包jdk-8u144-linux-x64.tar.gz上传到/usr/local/java文件夹内
4.在/usr/local/java目录执行tar -zxvf jdk-8u144-linux-x64.tar.gz
5.配置环境变量
①:vim /etc/profile在文件末尾加上如下配置:
JAVA_HOME=/usr/local/java/jdk1.8.0_144
CLASSPATH=$JAVA_HOME/lib/
PATH=$PATH:$JAVA_HOME/bin
export PATH JAVA_HOME CLASSPAT
然后wq保存退出
②:执行: source /etc/profile命令使配置生效
③:查看是否安装成功:java -version
二.安装zookeeper
1.下载版本: https://mirrors.bfsu.edu.cn/apache/zookeeper/
2.tar -zxvf 文件名称 解压版本
3.进入文件:cd 文件名/conf
4.将zoo_sample.cfg这个文件复制为zoo.cfg : cp zoo_sample.cfg zoo.cfg
5.进行修改:dataDir默认地址是/tmp/zookeeper 数据存放地址可以随便写(前提是有这个文件)
6.进入zookeeper下的bin目录执行启动:./zkServer.sh start
三.安装kafka
1.下载kafka版本:https://mirrors.bfsu.edu.cn/apache/kafka/
2.解压kafka包:tar -xzf 包名
3.启动kafka之前要确保zookeeper已经启动
4.启动kafka之前,需要修改kafka配置文件中的zookeeper地址
5.vi config/server.properties 修改zookeeper.connect=127.0.0.1:2081(这里修改成自己安装的zookeeper地址和端口即可)
四. 命令
1.启动命令:
启动zooleeper:./zkServer.sh start 到zooleepr文件下运行kafka:bin/kafka-server-start.sh config/server.properties后台运行 kafka命令:bin/kafka-server-start.sh -daemon config/server.properties(切到kafka文件下) 2.查询kafka命令
创建topic(4个分区,2个副本): bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 4 --topic testkafka版本 >= 2.2: bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test分区扩容 kafka版本 < 2.2: bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic topic1 --partitions 2kafka版本 >= 2.2: bin/kafka-topics.sh --bootstrap-server broker_host:port --alter --topic topic1 --partitions 2删除topicbin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test查询集群描述: bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181查询集群描述二:bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic foo --describetopic列表查询: bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list



