kafka清空topic数据命令
时间: 2023-12-08 21:05:31 浏览: 114
Kafka源码系列教程之删除topic
清空 Kafka Topic 的命令如下:
```
bin/kafka-topics.sh --zookeeper <zk_host:port/chroot> --alter --topic <topic_name> --config retention.ms=1000
```
其中,`<zk_host:port/chroot>` 是 Kafka 集群中的 ZooKeeper 地址,`<topic_name>` 是要清空的 Topic 名称。
执行完上述命令后,等待一段时间后 Kafka 会自动清空该 Topic 中的所有数据。如果想要保留一些数据,可以调整命令中的 `retention.ms` 参数,该参数设置该 Topic 中消息的最大保留时间。
阅读全文