class FinancialInstrumentProducer {

    public void sendMessage(String topic, String key, Map<String, Object> message) {
        kafkaTemplate.send(topic, key, message);
    }

    @Autowired public  FinancialInstrumentProducer(LogAwareKafkaTemplate<String, Object> kafkaTemplate);

}