​在Windows环境下下安装Kafka​

     阅读:47

1 安装JDK

Java环境变量配置(Windows)

1.1下载安装JDKJRE

JDKJava Development Kit)是Java语言的软件开发工具包,包括Java运行环境、Java开发工具、Java基础类库。

JREJava Runtime Environment)是Java运行环境,运行Java环境所必须的环境集合。

下载地址:Java Downloads | Oracle

 

1.2 配置Java环境变量

计算机右键菜单--->属性--->高级系统设置--->环境变量--->系统变量-->新建..

JAVA_HOME指向JDK安装路径。

变量名:JAVA_HOME 
变量值:C:\Program Files\Java\jdk1.8.0_60

CLASSPATH

变量名:CLASSPATH
变量值:.;%JAVA_HOME%\lib\dt.jar;%JAVA_HOME%\lib\tools.jar;

找到Path变量,在变量值最后输入如下内容。

变量名:Path
变量值:%JAVA_HOME%\bin;%JAVA_HOME%\jre\bin;

1.3 验证Java环境变量配置是否成功

打开windows命令行窗口,输入java并回车。

 

 

打开windows命令行窗口,输入javac并回车。

 

2 安装Zookeeper

2.1  下载安装文件: http://zookeeper.apache.org/releases.html

2.2  解压文件到D:\Program Files\zookeeper-3.4.14

2.3  打开zookeeper-3.4.14\conf,把zoo_sample.cfg重命名成zoo.cfg

2.4  在文本编辑器里打开zoo.cfg

2.5  dataDir的值改成如下:

dataDir=D:/Program Files/zookeeper-3.4.14/data

2.6  添加如下系统变量:

  • 在系统变量中添加ZOOKEEPER_HOME 值为D:\Program Files\zookeeper-3.4.14
  • 编辑Path:在现有的值后面添加 ;%ZOOKEEPER_HOME%\bin;

2.7 运行Zookeeper:打开cmd然后执行zkserver

注意,cmd窗口不要关闭。

3 安装Kafka

3.1 下载安装文件: Apache Kafka

3.2  解压文件到D:\kafka_2.12-2.3.0

3.3  打开kafka_2.12-2.3.0\config

3.4  在文本编辑器里打开 server.properties

3.5  log.dirs的值改成如下:

log.dirs=D:/kafka_2.12-2.3.0/kafka-logs

3.6  打开cmd,进入kafka文件目录: cd D:\kafka_2.12-2.3.0

3.7  输入并执行:

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

注意,cmd窗口不要关闭。

 

4 创建topic

4.1 打开cmd,进入cd D:\kafka_2.12-2.3.0\bin\windows

4.2 创建一个topic

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

5 创建producer

5.1 打开cmd,进入cd D:\kafka_2.12-2.3.0\bin\windows

5.2 启动producer

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

6 创建consumer

6.1 打开cmd,进入cd D:\kafka_2.12-2.3.0\bin\windows

6.2 启动consumer

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test

7 测试

producer命令行中任意输入内容,回车;在其他consumer命令行中能看到相应消息。

8 其他命令

8.1 列出主题

kafka-topics.bat --list --zookeeper localhost:2181

8.2 描述主题

kafka-topics.bat --describe --zookeeper localhost:2181 --topic [Topic Name]

8.3 从头读取消息

kafka-console-consumer.bat --bootstrap-server localhost:2181 --topic [Topic Name] --from-beginning

8.4 删除主题

kafka-run-class.bat kafka.admin.TopicCommand --delete --topic [topic_to_delete] --zookeeper localhost:2181

参考  Setting Up and Running Apache Kafka on Windows OS