@Test
public void addKafkaProducer(TestContext context) {

    repository.addKafkaProducer(new KafkaConfiguration(patternFrom("my.topic.*"), configs));
    context.assertTrue(repository.findMatchingKafkaProducer("my.topic.x").isPresent());
    context.assertFalse(repository.findMatchingKafkaProducer("my.other.topic.x").isPresent());
}