Kafka安装

下载安装包

Kafka 下载地址： 官网下载

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

解压

解压后就可以了，里面是支持Linux和Windows启动脚本的。

修改配置

修改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 // 服务监听端口

启动服务

使用cmd打开kafka的根目录，执行以下操作：

1. 启动zookeeper

bin\windows\zookeeper-server-start.bat config\zookeeper.properties

2. 启动kafka

bin\windows\kafka-server-start.bat config\server.properties

3. 创建主题topic，topic = demo

bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

查看创建的topic

bin\windows\kafka-topics.bat --list --bootstrap-server localhost:9092

4. 启动生产者 producer

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic demo

启动生产者之后进入编辑页面，发送一条消息 “nihao”，

5. 启动消费者 customer

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic demo --from-beginning

当消费者启动之后，收到了之前生产者发送的 “nihao”