}
@AfterAll
- static void joinConsumerTasks(@Autowired ConsumerTaskRunner consumerTaskRunner)
+ static void joinConsumerTasks(
+ @Autowired ConsumerTaskRunner consumerTaskRunner)
+ throws InterruptedException
{
KafkaTestUtils.joinConsumerTasks(consumerTaskRunner);
}