kafka是一个分布式的基于发布/订阅模式消息队列,主要应用于大数据实时处理领域。初次接触,记录一下,安装之前,首先要确定本地安装了JDK

安装zookeeper

zookeeper 可以作为给分布式系统提供协调服务的工具被 kafka 所依赖,所以我们要先安装zookeeper
下载地址:https://archive.apache.org/dist/zookeeper/
我这边下载的是3.7.1版本的
在这里插入图片描述
下载完成之后就可以把压缩包解压到一个目录当中,然后我们需要在目录中创建两个文件夹,用于储存数据和日志文件在这里插入图片描述
打开conf–>将zoo_sample.cfg文件复制一份并重命名为zoo.cfg,然后打开他修改配置项,将数据储存路径和日志储存路径配置上去
在这里插入图片描述
完成之后就可以到bin目录下启动zookeeper了,启动命令:zkServer.cmd
启动成功后再打开一个cmd窗口,启动:zkCli.cmd
在这里插入图片描述
当显示这个界面 就说明zookeeper安装启动成功了

安装kafka

下载地址:https://kafka.apache.org/downloads
我这里安装的是0.11.0.0版本
在这里插入图片描述
安装完之后解压,这里有一点要注意,kafka解压的目录中不能带有空格,不然启动的时候会失败,比如
Program Files目录;解压完后我们就可以来启动kafka

先启动zookeeper服务,到kafka的bin–>windows目录,用cmd打开窗口
启动zookeeper命令:zookeeper-server-start.bat …\config\zookeeper.properties
在这里插入图片描述
如果发送报错情况,可以看一下这里是否端口号被占用,可以用 netstat -ano | findstr 2181 找到占用端口的pid,然后用 taskkill /f /pid pid号 关闭即可
在这里插入图片描述
完成zookeeper服务启动之后,接下来启动kafka,同样先在windows目录下打开cmd命令行
启动kafka命令:kafka-server-start.bat …\config\server.properties
在这里插入图片描述
可以看到kafka也启动成功了

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐