软件开发架构师

10 删除topic中的数据

架构 147 2019-03-22 23:13

1 打开    server.properties
2  添加一条:  delete.topic.enable=true

3  执行命令:   bin/kafka-topics.sh --delete --zookeeper 9.37.138.215:2181, 9.42.18.65:2181, 9.37.201.53:2181 --topic kfk

执行完后,topic中现有的数据就没有了(其实没有真正删除), offset从0开始,此时consumer 的 subscribe可以接收到数据。

 

文章评论