1、软件下载

kafka运行需要有jdk+zookeeper环境才能够使用,官网下载

https://www.apache.org/dyn/closer.cgi/zookeeper/

http://kafka.apache.org/downloads

2、zookeeper安装

将下载下来的包解压一下,然后在conf目录下将zoo_sample.cfg改成zoo.cfg

修改zoo.cfg将里面的dataDir的路径

dataDir=F:\tools\logs\zookeeper

配置环境变量,类似于jdk

运行zookeeper,在cmd里面输入zkserver

3、kafka安装

将下载下来的安装包解压,并进入到conf目录下面找到server.properties文件,并修改

log.dirs=F:\tools\logs\kafka
zookeeper.connect=localhost:2181

为了方便也可以配置一下环境变量,%KAFKA_HOME%\bin\windows到path

启动kafka

kafka-server-start.bat %KAFKA_HOME%\config\server.properties

创建一个topic

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

开启生产者

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

开启消费者

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

最新文章

  1. php页面如何增加下载软件功能
  2. PHP基础之 重载 的实现方式
  3. C++控制台应用程序之贪吃蛇(改进版)
  4. [转载]jQuery.extend 函数详解
  5. VMware Player安装centos
  6. Winform_devexpress开发框架主界面设计
  7. Collaborative Filtering(协同过滤)算法详解
  8. exp和imp的使用场合
  9. js中字符串可以调用的方法
  10. Array.from();Object.keys();Array.map()
  11. yii2 gridview checkbox
  12. Java实现视频转码或压缩demo.
  13. Tenka 1 Computer Contest C-Align
  14. python常用库 - NumPy 和 sklearn入门
  15. 微信导出群记录V3.0
  16. Python:Windows8下安装BeautifulSoup
  17. Spark1.0.0属性配置
  18. codevs 2291 糖果堆
  19. eclipse的jdk版本和spring冲突问题WARN XmlWebApplicationContext:1060 - Exception thrown from LifecycleProcessor on context close
  20. java多线程16:join()的使用

热门文章

  1. 对象有时候打印出来的日志可能是以map的格式存在,转成json格式
  2. (原创)odoo15(master)下,列表导出权限控制
  3. 若依分离版本+Nginx+docker+jenkins 部署
  4. 专业视频图片水印清除工具丨HitPaw Watermark Remover 2.1.3
  5. 批量检测URL中的关键词,并且将不含有关键词的URL输出到txt文件当中
  6. https://github.com/wuweilin/springboot-login-demo
  7. Windows打开回收站的几种方式
  8. maven静态资源过滤
  9. Wix Setting language and code page attributes
  10. uniapp改变icon