环境要求

• kafka2
• mac（linux系统操作大同小异）

步骤

下载安装

Mac系统中可以使用brew工具，只需要一条命令就完成了下载与安装的过程，关于brew安装–>Mac安装brew

brew install kafka

等待安装完成后可以看到kafka安装路径和kafka配置文件的路径：

/usr/local/Cellar/kafka/2.1.0
/usr/local/etc/kafka/

启动kafka

kafka依赖zookeeper，而kafka中默认已有一个单机版的zookeeper供使用（实际生产环境中不推荐使用默认的zookeeper）

1. 开启zookeeper

• cd到kafka的安装目录下

cd /usr/local/Cellar/kafka/2.1.0

• 执行脚本启动zookeeper：

bin/zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties

/usr/local/etc/kafka/zookeeper.properties 是zookeeper的配置文件，启动成功如下图：

2. 启动kafka

• 再打开一个控制窗口，cd到kafka的安装目录下

cd /usr/local/Cellar/kafka/2.1.0

• 执行脚本启动kafka：

bin/kafka-server-start /usr/local/etc/kafka/server.properties

测试

1. 首先创建一个主题（topic）

再打开一个控制窗口，cd到kafka的安装目录下

cd /usr/local/Cellar/kafka/2.1.0

执行命令，创建一个主题

bin/kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

–create 创建主题命令
–zookeeper localhost:2181 指定zookeeper
–replication-factor 1 指定副本个数
–partitions 1 指定分区个数
–topic test 主题名称为“test”

查看是否成功创建主题

bin/kafka-topics --list --zookeeper localhost:2181

2. 测试生产者（producer）与消费者（consumer）

打开一个窗口输入命令创建一个生产者：

bin/kafka-console-producer --broker-list localhost:9092 --topic test

打开一个窗口输入命令创建一个消费者：

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

使用生产者发送消息，消费者接受消息

测试成功