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可以接收到数据。

 

相关文章:

  • 2021-08-06
  • 2022-02-08
  • 2021-07-26
  • 2022-12-23
  • 2021-07-21
猜你喜欢
  • 2021-12-14
  • 2021-05-05
  • 2021-05-12
  • 2022-12-23
  • 2021-07-31
  • 2022-12-23
相关资源
相似解决方案