@Test
public void closeAll(TestContext context) {

    Async async = context.async();
    repository.addKafkaProducer(new KafkaConfiguration(patternFrom("my.topic.*"), configs));
    repository.addKafkaProducer(new KafkaConfiguration(patternFrom("my.other.topic.*"), configs_2));
    context.assertTrue(repository.findMatchingKafkaProducer("my.topic.zz").isPresent());
    context.assertTrue(repository.findMatchingKafkaProducer("my.other.topic.zz").isPresent());
    repository.closeAll().setHandler(event -> {
        context.assertFalse(repository.findMatchingKafkaProducer("my.topic.zz").isPresent());
        context.assertFalse(repository.findMatchingKafkaProducer("my.other.topic.zz").isPresent());
        async.complete();
    });
}