如何删除Kafka中的数据以及删除topic
如何删除Kafka数据已经以及删除topic呢?
1、删除数据
先启动Kafka实例
docker exec -it kafka-0 /bin/bash #进去容器
rm -rf /bitnami/kafka/data/* #删除数据
exit #退出
如果删除失败,可能是数据不存在于/bitnami/kafka/data,使用
cd /opt/bitnami/kafka/config cat server.properties | grep log.dirs #查看log.dirs的地址,即数据存放的地址
显示
rm -rf 循环删除该目录即可
切换到bin目录
cd /opt/bitnami/kafka/bin
./kafka-console-consumer.sh --bootstrap-server 192.168.57.140:9093 --topic test-topic #查看某个topic的数据
查看某一个topic的数据
无显示,删除成功。
2、删除topic
注意:.sh文件都要在
./kafka-topics.sh --delete --bootstrap-server localhost:9093 --topic test-topic #主机ip:端口 topic名
./kafka-topics.sh --list --bootstrap-server localhost:9092 #查看所有的topic
成功删除。