By

1、Mac安装kafka

1.1、下载地址

https://downloads.apache.org/kafka/2.7.0/

image-20210131181441475

1.2、启动

启动前需要先启动zookeeper

1.2.1、启动前启动zookeeper

1.2.2、启动前配置文件修改

打开配置文件 kafka/config/server.properties

解开注释: listeners=PLAINTEXT://localhost:9092

1.2.1、启动命令

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

1.3、基本使用

1.3.1、创建一个topic

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic ZongMan

1.3.2、查看topic列表

./kafka-topics.sh --list --zookeeper localhost:2181

1.3.3、创建一个生产者

./kafka-console-producer.sh --broker-list localhost:9092 --topic ZongMan

1.3.4、创建二个消费者

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

1.4、关闭

服务的关闭

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

./kafka-server-stop.sh