博客

Mac系统下建议不要用Homebrew下载，都不知道安装在哪里搞得目录麻烦的很。


官方文档阅读

1.

tar包下载

找到你想下载版本，我这里下载的3.0.0（如果觉得下载慢，可以复制下载链接到迅雷下载）

2.解压缩，

tar -xzf kafka_2.12-3.0.0.tgz


3.移动文件夹到你想存储的根目录下，命令

mv 要移动的文件目录名 准备移动到的位置


注意：如果显示Perssion权限不足，就使用

sudo su

命令，输入root密码，进行移动。

4.终端进入到kafka目录下，如下图

5.开启一个终端启动kafka中内置的zookeeper，

bin/zookeeper-server-start.sh config/zookeeper.properties

,启动成功如下

5.5可以先配置一下kafka的ip地址，地址为

/../kafka/config

，修改文件

vim server.properties


6.开启一个终端启动kafka，

bin/kafka-server-start.sh config/server.properties

启动成功如下

7.开一个终端，创建一个topic



bin/kafka-topics.sh --create --topic quickstart-event --bootstrap-server 上面对外暴露的ip:9092 --partitions 2 --replication-factor 1


注意：在较新版本（2.2 及更高版本）的 Kafka 不再需要 ZooKeeper 连接字符串，即- -zookeeper localhost:2181。使用 Kafka Broker的 –bootstrap-server localhost:9092来替代- -zookeeper localhost:2181。

注：查看已创建topic列表，

bin/kafka-topics.sh --list --bootstrap-server ip地址:9092


8.创建一个终端，并写入生产者的信息



bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server ip地址:9092





9.创建一个终端，用来消费者接受信息。



bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server ip地址:9092




成功了，开心ing！