TestContainers Kafka 清理

Question

我正在将 TestContainers 与 Kafka 一起使用，但我在测试中使用了缓存。

我已经构建了 Hello World Kafka Stream 应用程序，在我的测试中，我得到了答案：

Flat Map: Hello World!
Grouping: key=null work=hello
Grouping: key=null work=world
Key=hello value=7

我的测试非常简单，我正在创建 KafkaContainer 并向输入主题发送消息，然后检查输出主题。

@Container
public static KafkaContainer kafka = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:5.4.3"));

我的问题是：如何清理所有Kafka数据（或所有容器数据）？我可以在测试之间进行吗？

我相信每次 运行 测试我都需要使用全新的 Kafka 集群，而不是旧的。我用 my test.

创建了一个 GitHub 存储库

Answer 1

这不是 TestContainer 问题。

Kafka Streams 在 %AppData%\Local\Temp\kafka-streams

上创建本地缓存