2.mac下kafka的安装

1.首先从官网下载kafka压缩包,然后解压下载得到的kafka压缩包
2.mac下kafka的安装
2.配置环境变量

cd ~
vim .bash_profile

保存并source一下
2.mac下kafka的安装

3.启动

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

Jps查看进程,发现多了一个kafka
2.mac下kafka的安装
4.创建topic(指定zk)

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

查看所有topic:

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

2.mac下kafka的安装
5.生产消息(指定broker)

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

6.消费消息(指定zk)

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

2.mac下kafka的安装

官网文档存在错误,更新命令

kafka_2.11-0.9.0.1 wenlei$ bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic steven --from-beginning

2.mac下kafka的安装
2.mac下kafka的安装