kafka单机模式删除某一个topic的数据,并解决Topic xxxx is marked for deletion....报错

首先关闭当前topic的生产者与消费者,确保topic不再被使用,否则据说会有bug进入kafka的目录:cd ~softwarekafka_2.12-2.7.1b

首先关闭当前topic的生产者与消费者,确保topic不再被使用,否则据说会有bug

进入kafka的目录:

cd ~/software/kafka_2.12-2.7.1/bin

查看当前的全部topic:

./kafka-topics.sh --list --zookeeper localhost:2181

删除这个topic:

./kafka-topics.sh --zookeeper localhost:2181 --delete --topic topic的名称

如果出现报错:Topic xxxx is marked for deletion.Note: This will have no impact if delete.topic.enable is not set to true.

则需要修改server.properties文件:

cd ../config/
vim server.properties

然后写入(注意原始文件是没有这个配置的,需要在新的一行里写入这个配置):

delete.topic.enable=true

发布者:admin,转转请注明出处:http://www.yc00.com/web/1754581525a5177983.html

相关推荐

发表回复

评论列表(0条)

  • 暂无评论

联系我们

400-800-8888

在线咨询: QQ交谈

邮件:admin@example.com

工作时间:周一至周五,9:30-18:30,节假日休息

关注微信