kafka的使用详解

kafka的安装

1.安装jdk

2.安装ZooKeeper

3.安装kafka

4.验证、启动和关闭

　　启动ZooKeeper：zkServer.sh start

　　验证启动状态：zkServer.sh status

　　启动kafka：kafka-server-start.sh  server.properties(该配置文件的路径，能找到改文件既可)

　　关闭kafka：kafka-server-stop.sh

kafka的使用1（单机使用）

1.主题管理

通过kafka-topic.sh 脚本，加上相关参数完成主题的管理，包含创建主题、查看分区、删除主题等相关操作

如：

列出现有主题：kafka-topics.sh --list --zookeeper localhost:2181/myKafka

创建主题：kafka-topics.sh --zookeeper localhost:2181/myKafka --create --topic topic_1 --partitions 1 --replication-factor 1

查看分区：kafka-topics.sh --zookeeper localhost:2181/myKafka --list
删除主题：kafka-topics.sh --zookeeper localhost:2181/myKafka --delete --topic topic_1

2.生产消息

开启生产者：kafka-console-producer.sh --topic topic_1 --broker-list localhost:9092

3.消费消息

开启消费者：

　　kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_1
　　kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_1  --from-beginning(从头消费，不按照偏移量消费)

kafka的实战（通过API使用kafka）