Topic的增删改查

topic的作用就是将我们的数据进行分类

首先启动zookeeper：kafka是依赖于zookeeper的，所以启动用kafka要先启动zookeeper

zkServer.sh start

再启动kafka：

 kafka-server-start.sh $KAFKA_HOME/config/server.properties &

全部都启动完毕之后jps查看： 

 

启动成功！

创建一个Topic：

bin/kafka-topics.sh --zookeeper spark-local:2181 --create --replication-factor 1 --partitions 1 --topic myTopic

--topic后面跟的是创建topic的name
--replication-factor后面跟的是副本数   副本数不能大于可用的docker
--partitions后面跟的是分区数

 查看虚拟机中所有的Topic：

myTopic就是刚刚创建的topic 

然后再创建一个Topic------myTopi
 

删除Tipic：

kafka-topics.sh  --delete --zookeeper spark-local:2181  --topic myTopi

再查看就没有了myTopi

 

查看myTopic的详情：

bin/kafka-topics.sh --describe --topic myTopic --zookeeper spark-local:2181

 

 可以看到分区数，副本数，leader等信息。