环境要求
- 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)
- 开启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的配置文件,启动成功如下图:
- 启动kafka
- 再打开一个控制窗口,cd到kafka的安装目录下
cd /usr/local/Cellar/kafka/2.1.0
- 执行脚本启动kafka:
bin/kafka-server-start /usr/local/etc/kafka/server.properties
测试
- 首先创建一个主题(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
- 测试生产者(producer)与消费者(consumer)
打开一个窗口输入命令创建一个生产者:
bin/kafka-console-producer –broker-list localhost:9092 –topic test
打开一个窗口输入命令创建一个消费者:
kafka-console-consumer –bootstrap-server localhost:9092 –topic test –from-beginning
使用生产者发送消息,消费者接受消息