跳转到主内容
websoft网络软件专家 - 深耕网络技术,打造实用软件!

Kafka删除主题简洁易懂的指南

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

相关文章