安装
官网:http://kafka.apache.org/
中文文档:https://kafka.apachecn.org/documentation.html
下载地址:https://www.apache.org/dyn/closer.cgi?path=/kafka/2.7.0/kafka_2.13-2.7.0.tgz
启动
Kafka需要ZooKeeper的支持,所以启动Kafka之前需要先启动ZooKeeper,本地没有ZooKeeper环境的话可以使用Kafka打包的脚本进行启动。
启动ZooKeeper(localhost:2181)
bin/zookeeper-server-start.sh config/zookeeper.properties
启动Kafka(localhost:9092)
bin/kafka-server-start.sh config/server.properties
Topic操作
创建一个名为“test”的Topic,1个副本(—replication-factor),1个分区(—partitions)
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看Topic列表
bin/kafka-topics.sh --list --zookeeper localhost:2181
删除Topic(需要在config/server.properties中配置delete.topic.enable=true,否则只是单纯标记topic为删除,继续创建同名topic会提示已经存在)
bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test
查看Topic详情
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test