class KafkaProducerRepository {

    void addKafkaProducer(KafkaConfiguration config){
        log.info("About to add kafka producer from {}", config);
        this.kafkaProducers.put(config.getTopic(), KafkaProducer.create(vertx, config.getConfigurations()));
    }

    public  KafkaProducerRepository(Vertx vertx);

}