下载安装包

Kafka 下载地址： 官网下载

因为Kafka是由Scala语言编写的，图中的2.11和2.12指的是Scala的版本，意思就是由Scala2.11或2.12编译出的Kafka2.3.1二进制版本，而2.3.1才是Kafka的版本。这里我们直接下载二进制版本，如果下载源码版本需要自己去编译。

解压

> tar -xzf kafka
> cd kafka

修改配置文件

修改config下的server.properties文件

broker.id=1 // broker.id在每个节点上是唯一的
log.dirs=/opt/data/kafka //log.dirs指定的kafka中的数据的存放位置，默认的tmp目录会定期清空，所以需要修改，而且指定的目录需要在启动kafka之前创建好
zookeeper.connect=localhost:2181 // zookeeper.connect如果不指定，将使用kafka自带的zookeeper
listeners = PLAINTEXT://localhost:9092 // 服务监听端口

启动服务

1. 启动zookeeper

> bin/zookeeper-server-start.sh config/zookeeper.properties

2. 启动kafka

> bin/kafka-server-start.sh config/server.properties