要清除Kafka Topic内的数据,可以使用以下方法:
使用Kafka自带的命令行工具kafka-topics.sh:
kafka-topics.sh --zookeeper <zk_host:zk_port> --topic <topic_name> --delete
通过设置Topic的retention时间为0来立即删除数据:
kafka-configs.sh --zookeeper <zk_host:zk_port> --alter --entity-type topics --entity-name <topic_name> --add-config retention.ms=0
在Kafka机器上删除Topic的日志目录:
server.properties
配置文件中的log.dirs
参数找到。<log.dirs>/<topic_name>-0
。注意:这些方法都会导致数据永久删除,谨慎操作。确保在执行此操作之前备份需要保留的数据。