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)

上一篇:Spring官方RSocket Broker 0.3.0发布: 快速构建你的RSocket架构


下一篇:kafka之常用命令