ICode9

精准搜索请尝试: 精确搜索
首页 > 系统相关> 文章详细

基于Windows的Kafka自学笔记

2021-09-01 11:32:39  阅读:167  来源: 互联网

标签:bin bat Windows zookeeper kafka topic -- 自学 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

标签:bin,bat,Windows,zookeeper,kafka,topic,--,自学,Kafka
来源: https://www.cnblogs.com/PerformanceTesting/p/15211191.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有