新建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