安装

原本想想MySQL一样编译安装，遇到各种各样的问题，还是屈服了，没必要一开始就较劲。使用brew进行安装，非常方便。

brew install kafka

安装完之后，安装目录为：

# kafka安装目录
/usr/local/Cellar/kafka/2.1.0

# 配置文件目录
/usr/local/etc/kafka/

如果需要修改配置，可以进入对应目录，修改配置文件就好

启动

启动zookeeper

kafka是基于zookeeper的，启动kafka之前，需要先启动zookeeper

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

启动后，查看启动是否成功

# 先比较low地查找吧，后续补充上zookeeper的命令使用
ps aux | grep zookeeper

启动kafka

现在，可以尝试启动kafka了

/usr/local/Cellar/kafka/2.1.0/bin/kafka-server-start /usr/local/etc/kafka/server.properties &

查看启动是否成功

# 先比较low地查找吧，后续补充上kafka的命令使用
ps aux | grep kafka

指令小试牛刀

创建一个topic

# 命令行参数含义，后续补充，当前页不是很清楚，约莫能猜出个大概
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic sunday

查看topic列表

既然创建了一个，就要看下创建成功了没：

kafka-topics --list --zookeeper localhost:2181
# 输出：
__consumer_offsets
sunday

创建一个生产者

kafka-console-producer --broker-list localhost:9092 --topic sunday

创建二个消费者

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

这样，就可以在生产者生产消息，而消费者会自动消费消息。

服务的关闭

服务关闭的顺序是先kafka，然后zookeeper

# 关闭kafka
/usr/local/Cellar/kafka/2.1.0/bin/kafka-server-stop
#关闭zookeeper
/usr/local/Cellar/kafka/2.1.0/bin/zookeeper-server-stop

结束语

起航吧，kafka之旅