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 指定，带有主题名称的前缀。