window 下kafka 配置测试

1.准备工作

   1.1 java环境

   

  1.2 下载并解压到D:zookeeper-3.4.13  下载并解压到 D:kafka_2.12-2.1.0

2.安装zookeeper 、kafka 我安装在d盘根目录下

  2.1 D:zookeeper-3.4.13conf => zoo_sample.cfg重命名为zoo.cfg  并修改zoo.cfg 节点

  dataDir=D:/data/logs/zookeeper

 

 2.2 D:kafka_2.12-2.1.0config=> 并修改log.dirs 节点

 log.dirs=D:/data/logs/kafka

 

备注：路径要么是"/"分割，要么是转义字符"\"

 2.3配置环境变量

 ZOOKEEPER_HOME: D:zookeeper-3.4.13

 Path后追加 ;%ZOOKEEPER_HOME%in;

3.启动zookeeper 、kafka

  3.1启动zookeeper

  

 3.2启动Kafka

   命令：.inwindowskafka-server-start.bat .configserver.properties  cmd 切换到 D:kafka_2.12-2.1.0下执行

 

4.测试kafka

 4.1 创建topic

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

 

  备注：以上依次显示创建topic 和查询topic 

  4.2 开启生产者 消费者

  生产者命令：kafka-console-producer.bat --broker-list localhost:9092 --topic test

  消费者命令：kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning