我在kafka中使用testcontainers，但我的测试中得到了缓存。
我已经构建了hello world kafka流应用程序，通过测试，我得到了答案：

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集群，而不是旧集群。我用我的测试创建了一个github存储库。