如何清除或删除kafka 2.1.0版本中的主题

Question

希望在2.1.0版本中分享清除或删除Kafka主题的不同方法。我在这里发现了类似的问题清除Kafka主题，然而，接受的答案已被弃用，它适用于Kafka版本0.8及以下，因此创建了这个问题的答案。

这不是一个重复的问题。

Answer 1

默认情况下，Kafka保留消息168小时，也就是7天。如果你想强迫Kafaka清除这个话题，你可以通过多种方式来做到这一点。让我们详细看看每一个。

1.使用kafka-config.sh命令

暂时将保留策略更改为1秒。

kafka-configs.sh --zookeeper localhost:2181 --alter --entity-type topics --add-config retention.ms=1000 --entity-name text_topic

kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --describe --entity-name text_topic
Configs for topic 'text_topic' are retention.ms=1000

kafka-configs.sh --zookeeper localhost:2181 --alter --entity-type topics --delete-config retention.ms --entity-name text_topic

在删除现有主题之前，首先获取当前主题的分区和副本，因为您需要这些来重新创建主题。您可以通过运行主题的description来获取此信息

kafka-topics.sh --zookeeper localhost:2181 --describe --topic text_topic

Topic:text_topic        PartitionCount:3        ReplicationFactor:3     Configs:
        Topic: text_topic       Partition: 0    Leader: 0       Replicas: 0     Isr: 0

删除主题。

kafka-topics.sh --zookeeper localhost:2181 --delete --topic text_topic

使用复制和分区详细信息重新创建主题。

kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic text_topic

1. 从所有节点停止zookeeper和kafka。
2. 从所有节点清除kafka日志。kafka将其日志文件存储在/tmp/kafka-logs/mytopic-0中，其中/tmp/kafka-logs由log.dirAttribute
指定
3. 重新启动zookeeper和Kafka。

希望这有帮助！！