安装的方法:

利用终端直接安装

brew install kafka

通过brew安装,会默认直接安装最新的版本。

因为我的电脑系统版本比较低,所以brew不支持最新的kafka版本。本文介绍的是通过官网下载安装包的方式。

通过官网下载安装包安装

有两个步骤:

  • 下载zookeeper(或者也可以使用kafka内置的zookeeper),因为kafka依赖zookeeper,所以在启动kafka前必须先启动zookeeper。
  • 下载Kafka

下载Zookeeper

下载地址:http://archive.apache.org/dist/zookeeper/

选择自己电脑合适的版本。

之后进到zookeeper的相对应的目录

解压(以下是本机的对应目录)

cd Downloads
tar -xzf zookeeper-3.4.6.tar.gz

解压之后往conf文件夹下加一个zoo.cfg
注意:里面的dataDir和DataLogDir要修改一下,换成你自己电脑上的zookeeper地址

# 服务器与客户端之间交互的基本时间单元(ms) 
tickTime=2000   
# zookeeper所能接受的客户端数量 
initLimit=10  
# 服务器和客户端之间请求和应答之间的时间间隔 
syncLimit=5
# zookeeper中使用的基本时间单位, 毫秒值.
tickTime=2000
# 数据目录. 可以是任意目录.
dataDir=你的zookeeper路径+/dataDir
# log目录, 同样可以是任意目录. 如果没有设置该参数, 将使用和#dataDir相同的设置.
dataLogDir=你的zookeeper路径+/dataLogDir
# t监听client连接的端口号.
clientPort=2181

在这里插入图片描述

下载kafka

下载地址:https://kafka.apache.org/downloads.html

注意:一定不要下成源文件了,是不带有-src 的文件

解压(以下是本机的对应目录)

cd Downloads
tar -xzf kafka_2.11-2.3.1.tar

启动zookeeper

##进入到自己相对应的目录
cd Downloads/zookeeper-3.4.6
bin/zkServer.sh start

看到下面这样就启动成功了!

在这里插入图片描述

启动kafka

另起窗口

进入到自己相对应的目录

##进入到自己相对应的目录
cd Downloads/kafka_2.11-2.3.1
##启动kafka
bin/kafka-server-start.sh config/server.properties

创建topic

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
可以通过下面命令查看topic
bin/kafka-topics.sh --list --zookeeper localhost:2181

创建生产者

另起窗口

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my_test

创建消费者

另起窗口

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_test --from-beginning

到这里就所有就准备就绪了!!!

此时,你在生产者中写一个信息,消费者中就会出现一个信息

在这里插入图片描述

在这里插入图片描述

单点的kafka环境部署完毕!!!

Logo

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

更多推荐