kafka的命令使用

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

终端显示

kafka manager显示

注：可通过Add Partitions按钮对topic进行添加分区

7.发送消息

kafka-console-producer --broker-list localhost:9092 --topictest

注：这里输入的时候建议将localhost换成本机的ip地址，这里localhost容易出现识别出错的问题

发送消息：hello world!

8.消费消息

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

注：1.这里输入的时候建议将localhost换成本机的ip地址，这里localhost容易出现识别出错的问题

        2.producer发送消息和consumer消费消息要建立两个终端

接受到了消息:hello world!