kafka的安装运行

一，安装JAVA JDK

二，安装ZooKeeper

1,下载安装包http://zookeeper.apache.org/releases.html#download

2，解压并进入ZooKeeper目录，如：F:\kafka\zookeeper_core\apache-zookeeper-3.6.2-bin\conf

3，将“zoo_sample.cfg”重命名为“zoo.cfg”

4,打开“zoo.cfg”找到并编辑dataDir=F:\\kafka\\zookeeper_core\\snapshot(必须以\\分割)

5,添加系统变量:ZOOKEEPER_HOME = F:\kafka\zookeeper_core\apache-zookeeper-3.6.2-bin

6,编辑path系统变量，添加路径:%ZOOKEEPER_HOME%\bin

7，打开cmd，输入“z'kServer”,运行Zookeeper,如下图所示

不要关闭该窗口

三，安装Kafka

1,下载安装包：http://kafka.apache.org/downloads，下载二进制版本

2，解压并进入Kafka目录，F:\kafka\kafka_core\kafka_2.13-2.6.0

3，进入config目录找到文件server.propertes并打开

4，找到并编辑log.dirs=F:\kafka\kafka_core\kafka_2.13-2.6.0\kafka-logs

5，找到并编辑zookeeper.connect=localhost:2181

6，Kafka会按照默认，在9092端口上运行，并连接zookeeper的默认接口，：2181

7，进入Kafka安装目录F:\kafka\kafka_core\kafka_2.13-2.6.0，打开命令窗口，输入命令

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

或bin\kafka-server-start.sh config\server.properties

不要关闭该窗口

四，测试

1，创建主题：进入kafka安装目录：F:\kafka\kafka_core\kafka_2.13-2.6.0，打开命令窗口，输入命令

 .\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

 不要关闭该窗口

查看主题输入

.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

 3，创建生产者，打开命令窗口，进入kafka安装目录，输入命令

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

 不要关闭该窗口

4，创建消费者，打开命令窗口，进入kafka安装目录，输入

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

 此时，往生产者窗口写入消息，消费者窗口也能同步接收消息

5，查看topic,打开命令窗口，进入kafka安装目录，输入命令

.\bin\windows\kafka-topics.bat --describe --zookeeper localhost:2181 --topic

test

 

 

 

 

参考连接：https://blog.csdn.net/weixin_38004638/article/details/91893910