public class MessageProducer {
    private static final String MESSAGE_TOPIC_CUSTOMER = "customer.topic";

    @Autowired
    private KafkaTemplate<String, Customer> template;

    public void sendEmail(Customer customer) {
        template.send(MESSAGE_TOPIC_CUSTOMER, customer);
    }

}