Sender.java

@Slf4j
public class Sender {

    @Autowired
    private KafkaTemplate<String, FulfillmentRequestEvent> kafkaTemplate;

    public void send(String topic, FulfillmentRequestEvent payload) {

        log.info("sending payload='{}' to topic='{}'", payload, topic);
        kafkaTemplate.send(topic, payload);
    }
}