admin 管理员组文章数量: 887019
这篇文章主要是来记录我在windows系统上面，安装kafka的步骤，以及踩过的坑
准备工作：
去官网下载zookeeper相关的文件 http://zookeeper.apache 3.4.11 版本
官网下载 kafka相关文件 http://kafka.apache 下载的版本是 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 输入节点信息及统计信息
版权声明：本文标题：windows 系统 上启动kafka 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://www.freenas.com.cn/jishu/1728986090h1303508.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。
发表评论