@SuppressWarnings("FutureReturnValueIgnored")
    private void sendObject(final RegisteredService key, final DistributedCacheObject<RegisteredService> item) {
        val itemKey = buildKey(key);
        val future = kafkaTemplate.send(topic, itemKey, item);
        future.whenComplete((result, ex) -> {
            LOGGER.trace("Published [{}]", result);
            LoggingUtils.error(LOGGER, ex);
        });
    }
This is {@link RegisteredServiceKafkaDistributedCacheManager}.

@author Misagh Moayyed
@since 6.3.0
support/cas-server-support-service-registry-stream-kafka/src/main/java/org/apereo/cas/services/RegisteredServiceKafkaDistributedCacheManager.java