@Override
    @SuppressWarnings("FutureReturnValueIgnored")
    public CasEvent saveInternal(final CasEvent event) {
        val eventToSend = event.assignIdIfNecessary();
        val topic = casProperties.getEvents().getKafka().getTopic().getName();
        val future = kafkaEventRepositoryTemplate.send(topic, eventToSend);
        future.whenComplete((result, ex) -> {
            LOGGER.trace("Published [{}]", result);
            LoggingUtils.error(LOGGER, ex);
        });
        return eventToSend;
    }
This is {@link KafkaCasEventRepository}.

@author Misagh Moayyed
@since 7.3.0
support/cas-server-support-events-kafka/src/main/java/org/apereo/cas/support/events/kafka/KafkaCasEventRepository.java