Kafka在window上安装部署

准备工作

1.安装java环境

如果没有安装看这里:https://www.cnblogs.com/wangzhaobo/p/11343304.html

2.安装zookeeper

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

解压目录: D:Tool,

1. 进入Zookeeper设置目录，D:Toolzookeeper-3.4.13conf
2. 将“zoo_sample.cfg”重命名为“zoo.cfg”
3. 在文本编辑器（如notepad）中打开zoo.cfg
4. 找到并编辑dataDir=D:/Tool/zookeeper-3.4.13/tmp (可以自定义文件夹)
5. 与Java中的做法类似，我们在系统环境变量中添加：
   　　a. 在系统变量中添加ZOOKEEPER_HOME =D:Toolzookeeper-3.4.13
   　　b. 编辑path系统变量，添加为路径 %ZOOKEEPER_HOME%in;
6. 在zoo.cfg文件中修改默认的Zookeeper端口（默认端口2181,可以不用修改）

测试 : 打开新的cmd，输入zkServer，运行Zookeeper,成功如下所示,

3.安装kafka

下载 http://kafka.apache.org/downloads.html,注意要下载二进制版本的,

解压到目录 D:Toolkafka_2.11-2.1.1

1. 编辑文件Kafka配置文件， D:Toolkafka_2.11-2.1.1configserver.properties
2. 找到并编辑log.dirs=D:Toolkafka_2.11-2.1.1kafka-log, (自定义文件夹)
3. 找到并编辑zookeeper.connect=localhost:2181。表示本地运行(默认的可以不改)
4. Kafka会按照默认，在9092端口上运行，并连接zookeeper的默认端口：2181。

运行和测试

注意：在启动Kafka前，先运行Zookeeper实例。 (前面的cmd命令:zkserver)

1.启动Kafka服务器

新建cmd窗口:

cd D:Toolkafka_2.11-2.1.1 
.inwindowskafka-server-start.bat .configserver.properties

如果报错,'wmic' 不是内部或外部命令,也不是可运行的程序.
在环境变量的path里面添加C:WindowsSystem32wbem;

2.创建主题

新建cmd窗口:

cd D:Toolkafka_2.11-2.1.1inwindows
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic haha

3.创建生产者

新建cmd窗口:

cd D:Toolkafka_2.11-2.1.1inwindows
kafka-console-producer.bat --broker-list localhost:9092 --topic haha

4.创建消费者

新建cmd窗口:

cd D:Toolkafka_2.11-2.1.1inwindows
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic haha --from-beginning

5.生产消息并消费

相关文章:

1. php使用kafka
   https://www.cnblogs.com/wangzhaobo/p/14346329.html
2. php在windows上安装kafka扩展
   https://www.cnblogs.com/wangzhaobo/p/14345760.html

转:将军上座