kafka基本命令
通过kafka-topics.sh脚本来创建一个名为topic-test1并且副本数为2、分区数为4的topic： bin/kafka-topics.sh --create --zookeeper 192.168.0.2:2181/kafka100 --topic topic-test1 --replication-factor 2 --partitions 4
查看topic 属性： bin/kafka-topics.sh --zookeeper zk1:2181 --describe --topic topicname bin/kafka-topics.sh --list --zookeeper 192.168.244.201:2181
增加分区数： bin/kafka-topics.sh --zookeeper zk_host:port --alter --topic my_topic_name--partitions 40
增加配置： bin/kafka-topics.sh --zookeeper zk_host:port --alter --topic my_topic_name --config flush.messages=1
删除配置： bin/kafka-topics.sh --zookeeper zk_host:port --alter --topic my_topic_name --delete-config flush.messages=1
删除topic: 目前删除操作在默认情况下只是打上一个删除的标记，在重新启动kafka 后才删除。如果需要立即删除，则需要在server.properties中配置delete.topic.enable=true。 bin/kafka-topics.sh --zookeeper zk_host:port --delete --topic my_topic_name
参考地址： https://blog.csdn.net/LOUISLIAOXH/article/details/51597173?utm_medium=distribute.pc_relevant_t0.none-task-blog-BlogCommendFromMachineLearnPai2-1.channel_param&depth_1-utm_source=distribute.pc_relevant_t0.none-task-blog-BlogCommendFromMachineLearnPai2-1.channel_param
https://blog.csdn.net/yehuang_0801/article/details/62891971
