kafka安装
1、Mac安装kafka
1.1、下载地址
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