1.直接启动kafka&zookeeper:
zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties &kafka-server-start /usr/local/etc/kafka/server.properties &
或通过brew services插件启动
brew services start zookeeper
brew services start kafka
2.启动Kafka Manager:
进入到kafka Manager目录下,cd /Users/xingshulin/Downloads/Kafka/kafka-manager-1.3.3.7
执行nohup bin/kafka-manager -Dconfig.file=conf/application.conf
3.进入到Kafka Manager页面localhost:9000,点击Add Cluster 添加集群
4.填写完前两项就可保存,剩下的选项根据自己的需求进行勾选,这里我只填写了集群名称和zookeeper主机地址
5.创建topic
kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
6.查看创建的topic
kafka-topics --list--zookeeper localhost:2181
注:可通过Add Partitions按钮对topic进行添加分区
7.发送消息
kafka-console-producer --broker-list localhost:9092 --topictest
注:这里输入的时候建议将localhost换成本机的ip地址,这里localhost容易出现识别出错的问题
8.消费消息
kafka-console-consumer --bootstrap-server localhost:9092--topic test --from-beginning
注:1.这里输入的时候建议将localhost换成本机的ip地址,这里localhost容易出现识别出错的问题
2.producer发送消息和consumer消费消息要建立两个终端