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(从头消费,不按照偏移量消费)