windows下部署kafka_2.12-1.1.0

时间：2021-06-14 08:23:29

安装JDK

安装zookeeper

下载地址：https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.4.12/zookeeper-3.4.12.tar.gz

解压至一个目录

进入conf目录

复制zoo_sample.cfg，并重命名为zoo.cfg

编辑zoo.cfg文件

修改dataDir路径，如dataDir=H:\\proj\\zookeeper-3.4.12\\tmp

添加环境变量

ZOOKEEPER_HOME = H:\proj\zookeeper-3.4.12

编辑path系统变量，添加路径

%ZOOKEEPER_HOME%\bin

启动zookeeper

打开cmd，输入zkServer，运行Zookeeper

安装kafka

下载地址：https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/1.1.0/kafka_2.12-1.1.0.tgz

解压至一个目录

进入config目录

编辑server.properties文件
修改log.dirs路径，如log.dirs=H:\\proj\\kafka_2.12-1.1.0\\kafka-logs
修改zookeeper.connect=localhost:2181

启动kafka

进入kafka安装目录

新建一个startup.bat并编辑输入

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

运行startup.bat

可能会遇到如下问题：

H:\proj\kafka_2.12-1.1.0>.\bin\windows\kafka-server-start.bat .\config\server.properties
Error: missing `server' JVM at `D:\Program Files (x86)\java\bin\server\jvm.dll'.
Please install or use the JRE or JDK that contains these missing components.

说明你只安装了jre，至官网下载并安装jdk即可

传送门：http://download.oracle.com/otn-pub/java/jdk/8u171-b11/512cd62ec5174c3487ac17c61aaa89e8/jdk-8u171-windows-x64.exe?AuthParam=1528562405_fc3a2f704a0b57c2c6fd0db92345334b

成功启动

windows下部署kafka_2.12-1.1.0

测试

创建主题

进入kafka安装目录

按下Shift+右键，选择“打开命令窗口”选项，打开命令行

输入如下语句

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

创建生产者

输入如下语句

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

创建消费者

进入kafka安装目录

按下Shift+右键，选择“打开命令窗口”选项，再打开一个命令行

输入如下语句

.\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic hello
标签：

相关文章