Kafka笔记--常用指令(新建、删除topic)

时间:2021-06-13 05:47:44

新建topic

./kafka-topics.sh --zookeeper 192.168.1.160:2181 --create --topic kafkatestsmall2 --partitions 2 --replication-factor 1

删除topic

首先需要设置server.properties,最后一行添加 delete.topic.enable=true

然后运行> ./kafka-topics.sh --zookeeper node4:2181,node3:2181 --delete --topic topic1