kafka安装与启动

一、安装

brew install kafka

image.png

• 默认安装上zookeeper

• 安装好kafka

• 根据安装提示找到安装位置和配置文件路径，以及启动方式

• 安装路径

/usr/local/Cellar/zookeeper/3.4.14
/usr/local/Cellar/kafka/2.3.0

• 配置文件路径

/usr/local/etc/kafka/server.properties
/usr/local/etc/kafka/zookeeper.properties

二、 启动

启动zookeeper

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

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

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

ps aux | grep zookeeper

启动kafka

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

验证是否启动成功

ps aux | grep kafka

三、测试

进入kafka安装目录

cd /usr/local/Cellar/kafka/2.3.0

创建一个topic

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

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

查看topic列表

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

创建一个生产者

# 新启动一个窗口输入命令创建一个生产者
kafka-console-producer --broker-list localhost:9092 --topic my_first_topic

• 生产者发送消息

  
  
  image.png

创建一个消费者

# 打开启动一个（多个）窗口输入命令创建一个（多个）消费者
kafka-console-consumer --bootstrap-server localhost:9092 --topic sunday --from-beginning

• 消费者接收消息

  
  
  image.png

四、关闭kafka服务

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

# 停止kafka
/usr/local/Cellar/kafka/2.3.0/bin/kafka-server-stop
# 停止zookeeper
/usr/local/Cellar/kafka/2.3.0/bin/zookeeper-server-stop