在线下载jdk1.8
$ wget --no-check-certificate --no-cookies --header "cookie: oraclelicense=accept-securebackup-cookie" http://download.oracle.com/otn-pub/java/jdk/8u131-b11/d54c1d3a095b4ff2b6607d0
96fa80163/jdk-8u131-linux-x64.rpm
添加执行命令
$ chmod +x jdk-8u131-linux-x64.rpm
执行rpm进行安装
$ rpm -ivh jdk-8u131-linux-x64.rpm
查看JDK是否安装成功
$ java -version
编辑环境变量
$ vim /etc/profile
export JAVA_HOME=/usr/java/jdk1.8.0_131
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib:$CLASSPATH
export JAVA_PATH=${JAVA_HOME}/bin:${JRE_HOME}/bin
export PATH=$PATH:${JAVA_PATH}
$ source /etc/profile
2.下载kafka安装包并解压
$ wget https://archive.apache.org/dist/kafka/2.4.0/kafka_2.11-2.4.0.tgz $ tar -xvf kafka_2.11-2.4.0.tgz $ cd kafka_2.11-2.4.0 $ ls bin config libs LICENSE logs NOTICE
3. 启动zookeeper
在kafka解压后进入目录启动zookeeper（后台运行） $ bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
4. 修改kafka配置文件
主要修改内容： broker.id=0 # 集群中的唯一标识 listeners=PLAINTEXT://10.20.30.40:9092 # kafka服务监听端口 log.dirs=/tmp/kafka-logs # 消息存储文件 zookeeper.connect=localhost:2181 # 链接zookeeper的地址
5. 启动Kafka
进入kafka目录执行启动命令
$ bin/kafka-server-start.sh -daemon config/server.properties
查看是否启动成功
$ ps -aux | grep server.properties $ jps
校验是否启动成功: 进入到zookeeper查看是否有kafka节点:brokers/ids
$ bin/zookeeper-shell.sh localhost:2181 ls /brokers/ids [0]
6. 创建/查看 Topic
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic hello 列出Topic $ bin/kafka-topics.sh --list --zookeeper localhost:2181 查看Topic描述信息 $ bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic hello
命令解析
--create： 指定创建topic动作
--topic： 指定新建topic的名称
--zookeeper： 指定连接zk的连接url，与server.properties中的{zookeeper.connect}一样
--config： 指定当前topic上有效的参数值
--partitions： 指定当前创建的kafka分区数量，默认为1个
--replication-factor：指定每个分区的复制因子个数，默认1个
--describe： 指定是展示详细信息命令
