Add / delete query of topic

topic The function of is to classify our data

First start zookeeper：kafka It depends on zookeeper Of , So for startup kafka We need to start first. zookeeper

zkServer.sh start

Restart kafka：

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

When everything is started jps see ： 

 

Successful launch ！

Create a Topic：

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

--topic This is followed by creating topic Of name
--replication-factor This is followed by the number of copies     The number of copies cannot be greater than the number of available docker
--partitions This is followed by the number of partitions

  View all in the virtual machine Topic：

myTopic Just created topic 

Then create another Topic------myTopi
 

Delete Tipic：

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

Check again and there will be no myTopi

see myTopic Details of ：

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

 

  You can see the number of partitions , replications ,leader Etc .