windows 系统 上启动kafka

这篇文章主要是来记录我在windows系统上面，安装kafka的步骤，以及踩过的坑

准备工作：

    去官网下载zookeeper相关的文件  http://zookeeper.apache.org  3.4.11 版本

    官网下载 kafka相关文件 http://kafka.apache.org 下载的版本是 2.11

    下载成功之后，把这两个文件都解压放在 D:\software 目录下

  接下来配置zookeeper相关文件并启动

    

在zookeeper文件目录下，conf文件夹，拷贝一份zoo_sample.cfg 文件命名为 zoo.cfg 然后将文件中 第12 行中改为本地路径

 端口不变，路径修改，ctrl+s保存

地址栏，cmd 命令，然后 直接 zkServer.cmd 就可以正常启动了，下图是正常启动后控制台日志

接下来启动kafka

cmd 命令下，切换到kafka的安装目录

一开始的时候，会启动失败，提示日志文件正在被占用，这个时候，删除掉 D:\tmp\kafka-logs（这个是我电脑上存放日志的路径） 下的日志，再次启动就可以了

接下来创建一个topic

在kafka \bin\window 目录下，创建topic  summer 

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

创建成功之后

我们开启一个窗口，去创建生产者

接下来是消费者

接下来切回到生产者模块

随便输入数据后回车

可以看到consumer 中打印出数据

好了，到此为止就已经成功启动kafka程序了

--------------------------------------------------------------------------------------------------------------------

kafka  config 文件夹下面

server.properties 

配置

auto.create.topics.enable=true

如果在创建消息时，topic不存在的话，会自动创建topic，否则就会报错

查询当前所有的topic

kafka /bin/windows 目录下

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

查询某个topic的详细信息：

kafka-topics.bat --descripe --topic mytest --zookeeper localhost:2181

第一行信息：topic 名称    分区数：1     副本数：1

第二行信息：topic 名称    当前分区：0      Leader Broker:0         副本：0     lsr(In-Sync Replica):0

Kafka中的信息是依赖于zookeeper 的，我们可以通过客户端连接到zookeeper服务器，来查询相关信息

连接到zk 服务器

执行 ls/ 

查询当前根路径下的所有节点

或者执行

ls2 /

额外输出相关信息

命令： ls /config/topics

查询config/topics 节点下的信息

ls2 /config/topics 输入节点信息及统计信息