TestContainers Kafka清理

Question

我在Kafka中使用TestContainers，但我的测试中使用的是come缓存。

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

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

我的测试非常简单，我创建KafkaContainer并向input主题发送消息，然后检查output主题。

@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上创建本地缓存