kafka-topics --delete --topic topic-name
kafka-topics --delete --topic my-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
以上就是Kafka删除主题简洁易懂的指南的详细内容,更多请关注php中文网其它相关文章!
Kafka Eagle是一款结合了目前大数据Kafka监控工具的特点,重新研发的一块开源免费的Kafka集群优秀的监控工具。它可以非常方便的监控生产环境中的offset、lag变化、partition分布、owner等,有需要的小伙伴快来保存下载体验吧!
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号