Step1:下载Kafka
brew install kafka
因为我已经安装了下图只是为了演示
安装的配置文件位置
/usr/local/etc/kafka/server.properties
/usr/local/etc/kafka/zookeeper.properties
Step2:启动服务这里我自己理解就好比redis等
运行kafka需要使用Zookeeper,所以你需要先启动Zookeeper,如果你没有Zookeeper,你可以使用kafka自带打包和配置好的Zookeeper。
ZooKeeper是一个[分布式]的,开放源码的[分布式应用程序]协调服务
启动 kafka 服务
./kafka-server-start /usr/local/etc/kafka/server.properties &
说明启动成功
Step3:创建一个主题(topic)好比盛放鸡蛋的篮子
创建篮子tuzisir
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic tuzisir
查看所有篮子
kafka-topics --list --zookeeper localhost:2181
运行结果
Step5:发送消息
向篮子tuzisir发送一条消息
kafka-console-producer --broker-list localhost:9092 --topic tuzisir
Step6:接收消息
从篮子tuzisir取出一条消息
kafka-console-consumer --bootstrap-server localhost:9092 --topic tuzisir --from-beginning
Step7:设置多个broker集群
到目前,我们只是单一的运行一个broker,没什么意思。对于Kafka,一个broker仅仅只是一个集群的大小,所有让我们多设几个broker。
待续