0

我正在编写一个测试类,它有多种需要 Kafka 的方法。我的应用程序使用 kafka 流全局存储,并且每个测试都需要清除存储。如何在不重新启动 EmbeddedKafka 或为每个测试重置 EmbeddedKafka 的情况下清除每个测试的存储?

4

0 回答 0