java - Kafka主题删除

Question

我使用 Kafka 作为事件源系统的事件存储。

在集成测试中，我通过运行删除 Kafka 中当前可用的所有主题

kafka-topics.sh --zookeeper localhost:2181 --delete --topic <topic-name> 

对于每个现有主题，确保“旧”数据不会影响后续测试。

我知道主题仅被标记为删除，但并未就地删除。而且，在大多数情况下，这对我来说没问题。

但在某些测试用例中，当我再次创建主题(通过将记录写入主题)时，主题不会被删除。在这种情况下，Kafka 会抛出 UnknownTopicOrPartitionException。

我想知道是否有某种方法可以强制Kafka删除该主题(或者至少增加删除的机会)。

如果您有任何建议，我将不胜感激。

我使用的是 Kafka 0.11.0.1

Answer 1

您不必删除主题即可丢弃“旧”数据。您可以通过停止 Kafka 服务器、删除主题的日志目录并再次启动 Kafka 来实现此目的。

主题的目录位于日志目录中，由代理配置中的 log.dir 指定，并带有主题名称的前缀。