class GridMeasurementPublishedEventProducer {

    public void send(final String measurement) {

        final GridMeasurementPublishedEvent event = this.mapper.map(measurement,
                GridMeasurementPublishedEvent.class);
        /*
         * No need for callback functionality now; by default, the template is
         * configured with a LoggingProducerListener, which logs errors and does
         * nothing when the send is successful.
         */
        this.kafkaTemplate.sendDefault(event);
    }

    @Autowired public  GridMeasurementPublishedEventProducer(
            @Qualifier("distributionAutomationKafkaTemplate") final KafkaTemplate<String, GridMeasurementPublishedEvent> kafkaTemplate,
            final DistributionAutomationMapper mapper);

}