windows下部署kafka_2.12-1.1.0

安装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

成功启动

测试

创建主题

进入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
发布了22 篇原创文章 · 获赞 4 · 访问量 2万+

猜你喜欢

转载自blog.csdn.net/qq_35921007/article/details/80637666