基于Windows的Kafka自学笔记

环境:Windows10

安装kafka:

Step1. 基于JDK

Step2. 安装Zookeeper,https://zookeeper.apache.org/releases.html 下载ZooKeeper,目前最新的稳定版本为 3.4.8 版本,用户可以自行选择一个速度较快的镜像来下载即可;

   启动:在Windows环境下,直接双击zkServer.cmd即可(D:\Kafka\apache-zookeeper\apache-zookeeper-3.7.0-bin\bin\zkServer.cmd)

    * 注意conf下是否有zoo.cfg文件,如果没有,可以复制一份zoo_sample.cfg后,重命名即可。

Step3. 下载Kafka,http://archive.apache.org/dist/kafka/2.4.0/kafka_2.11-2.4.0.tgz

   解压后进入bin\windows目录下,进行操作;

    启动Kafka .\bin\windows\kafka-server-start.bat .\config\server.properties

创建topic

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic test

创建producer

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

创建consumer

.\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test

删除topic

1. 在server.properties下面增加: delete.topic.enable=true 2..\bin\windows\kafka-topics.bat --delete --zookeeper localhost:2181 --topic test

查询topic test下的所有消息记录

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

相关文章

Windows2012R2备用域控搭建 前置操作 域控主域控的主dns:自...
主域控角色迁移和夺取(转载) 转载自:http://yupeizhi.blo...
Windows2012R2 NTP时间同步 Windows2012R2里没有了internet时...
Windows注册表操作基础代码 Windows下对注册表进行操作使用的...
黑客常用WinAPI函数整理之前的博客写了很多关于Windows编程的...
一个简单的Windows Socket可复用框架说起网络编程,无非是建...