kafka 是由 apache 软件基金会开发的一个开源流处理平台,由 scala 和 java 编写。kafka 是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者在网站中的所有动作流数据。
1、下载 windows 版 kafka 中间件
打开 https://kafka.apache.org/downloads 下载最新稳定版本或找个合适的稳定版本。
当前最新稳定版本为 kafka 2.13-3.7.1,点击 kafka_2.13-3.7.1.tgz 链接,即可下载。
2、解压 kafka_2.13-3.7.1.tgz
根目录结构(如下图):
3、自定义配置
3.1、修改 ip 地址
打开config 文件夹,修改 server.properties 文件 。
找到 #listeners=PLAINTEXT://:9092 并拷贝,粘贴后,根据实际情况修改,如果只是本地服务使用,可以用 localhost 或 127.0.0.1。
多台服务器都要连接,需要改为本地服务器的 ip 地址。
3.2、修改日志路径
打开config 文件夹,修改 server.properties 文件 。
找到 log.dirs=/tmp/kafka-logs,拷贝后注释它
粘贴后,把 /tmp/kafka-logs 改为 ./logs
值得注意的是,这个日志路径有可能导致启动时出现闪退的问题,暂时没有找到解决办法。
3.3、创建有标题的 bat
如果一台服务器运行多个用 cmd 打开的服务,就不好区分哪个是 kafka 的 bat 了,所以才需要 自建 kafka.bat,脚本如下:
title kafka
.\bin\windows\kafka-server-start.bat .\config\server.properties
pause
3.4、运行
想要 kafka 启动成功,首先要启动 apache-zookeeper
效果如下图就是成功的: