我使用@EmbeddedKafka注释,如下所示以获得一个kafka模拟:
@ExtendWith(SpringExtension.class)
@SpringBootTest
@EmbeddedKafka(partitions = 1,
topics = {"topic"},
brokerProperties = {
"auto.create.topics.enable=${topics.autoCreate:false}",
"delete.topic.enable=${topic.delete:true}",
"broker.id=2"})
public class KafkaUsersTest {
@Autowired
private EmbeddedKafkaBroker embeddedKafka;
@Test
public void test1() {
}
@Test
public void test2() {
}
...
}
现在,在测试完成后,我想关闭嵌入的kafka bean。像这样的:
@AfterAll
public void tearDown(){
embeddedKafka.getKafkaServers().forEach(KafkaServer::shutdown);
embeddedKafka.getKafkaServers().forEach(KafkaServer::awaitShutdown);
}
问题是:
-
@AfterAll方法只能是静态的。
-
如果我将其设为静态,那么embeddedKafka也必须是静态的,然后@Autowired注释将不起作用。
我想我可以将bean从一个测试转换到一个静态字段,然后在tearDown()中使用它,但它确实很难看。
在所有测试完成后只关闭一次bean的“良好实践”是什么?