2.mac下kafka的安装
1.首先从官网下载kafka压缩包,然后解压下载得到的kafka压缩包
2.配置环境变量
cd ~
vim .bash_profile
保存并source一下
3.启动
kafka-server-start.sh $KAFKA_HOME/config/server.properties
Jps查看进程,发现多了一个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
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
官网文档存在错误,更新命令
kafka_2.11-0.9.0.1 wenlei$ bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic steven --from-beginning