一、安装Kafka

1、 下载安装包

Apache Kafka

注意要下载二进制版本

3. 解压到相应文件夹，进入config目录下，找到server.properties文件，并作以下修改：

　　找到并编辑 log.dirs=D:\tmp\kafka-logs (kafka的解压目录，kafka-logs文件夹不用自己新建)

　　找到并编辑zookeeper.connect=localhost:2181 （一般默认就是localhost:2181）

        一些主要配置如下：

#1、broker实例id 这个是kafka集群区分每个节点的唯一标志符
broker.id=0

#2、监听的端口号
listeners=PLAINTEXT://:9092

#3、消息的存放路径
log.dirs=G:\kafka\kafka_2.11-2.4.1\logs

#4、kafka消息的保留时间，默认为7天即168小时【单位为：小时】
log.retention.hours=168

#5、log文件存放着msg，这里设置的是log文件的最大大小，默认最大为1个G【单位为：byte】
log.segment.bytes=1073741824

#6、kafka链接的zk地址
zookeeper.connect=localhost:2181

#7、kafka链接的超时时间
zookeeper.connection.timeout.ms=6000

#8、默认的分区数量
num.partitions=1

4. 启动kafka自带zk，win+R 输入cmd，打开命令窗口，进入安装目录 D:\kafka\，输入以下命令 ( 成功之后不要关闭窗口)

D:\kafka>.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

5. 启动kafka，win+R 输入cmd，打开命令窗口，进入安装目录 D:\kafka\，输入以下命令 ( 成功之后不要关闭窗口)

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

注意：不要关了这个窗口，启用Kafka前请确保ZooKeeper实例已经准备好并开始运行

二、测试

（linux直接在bin目录下.sh，windows需要进入bin\winndows下的.bat）

1、 创建主题，进入Kafka安装目录D:\Kafka\，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入

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

注意：不要关了这个窗口

2、查看主题输入：

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

3、创建生产者，打开一个新的命令窗口，进入安装目录 D:\kafka\，输入以下命令 ( 成功之后不要关闭窗口)

.\bin\windows\kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic test2

 4、创建消费者，打开一个新的命令窗口，进入安装目录 D:\soft\kafka\kafka_2.13-2.8.0，输入以下命令 ( 成功之后不要关闭窗口)

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

这里接收生产者的消息