TestContainers Kafka 清理

Posted 2023-03-28

【中文标题】TestContainers Kafka 清理

【英文标题】：TestContainers Kafka cleanup

【发布时间】：2021-07-14 18:53:13

【问题描述】：

我正在将 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 存储库。

【参考方案1】：

这不是 TestContainer 的问题。

Kafka Streams 在 %AppData%\Local\Temp\kafka-streams 上创建本地缓存