Kafka删除Topic命令教程
前提条件
已安装并运行Kafka集群。
具有管理员权限的用户。
删除Topic命令
参数
:指定要删除的Topic。
:要删除的Topic的名称。
示例
注意
在删除Topic之前,请确保该Topic中没有未提交的数据。如果存在未提交的数据,则删除Topic可能会导致
数据丢失
。
删除Topic后,该Topic将不可恢复。因此,在删除Topic之前,请仔细考虑。
常见问题
问:如何删除具有多个分区的Topic?
答:使用
参数指定要删除的分区数。例如,要删除具有3个分区的Topic,可以使用以下命令:
问:如何删除具有多个副本的Topic?
答:使用
参数指定要删除的副本数。例如,要删除具有2个副本的Topic,可以使用以下命令:
问:如何删除具有压缩的Topic?
答:使用
参数指定要删除的压缩类型。例如,要删除具有GZIP压缩的Topic,可以使用以下命令:
问:如何删除具有保留策略的Topic?
答:使用
参数指定要删除的保留时间。例如,要删除具有1天的保留时间的Topic,可以使用以下命令:
问:如何删除具有清理策略的Topic?
答:使用
参数指定要删除的清理策略。例如,要删除具有删除策略的Topic,可以使用以下命令:
kafka-topics --delete --topic topic-name--delete--topickafka-topics --delete --topic my-topic--partitionskafka-topics --delete --topic my-topic --partitions 3--replicaskafka-topics --delete --topic my-topic --replicas 2--compression-typekafka-topics --delete --topic my-topic --compression-type gzip--retention-mskafka-topics --delete --topic my-topic --retention-ms 86400000--cleanup-policykafka-topics --delete --topic my-topic --cleanup-policy delete