在Kafka中,创建一个topic后,不能直接删除它
kafka-topics.sh --list --zookeeper <zookeeper_host:port>
将<zookeeper_host:port>
替换为你的Zookeeper主机和端口。
kafka-topics.sh --delete --topic <topic_name> --zookeeper <zookeeper_host:port>
将<topic_name>
替换为你要删除的topic的名称,将<zookeeper_host:port>
替换为你的Zookeeper主机和端口。
请注意,在删除topic之前,确保该topic没有正在运行的消费者组或生产者。否则,删除操作可能会失败。此外,删除topic将导致所有与该topic相关的数据丢失,因此在执行此操作之前,请确保备份所有重要数据。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读:kafka建立topic如何监控