Kafka之安装启动及Topic操作命令

安装

官网: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

觉得内容还不错?打赏个钢镚鼓励鼓励!!👍