@Override
    @CanIgnoreReturnValue
    public DistributedCacheManager<RegisteredService, DistributedCacheObject<RegisteredService>, PublisherIdentifier>
        set(final RegisteredService key, final DistributedCacheObject<RegisteredService> item,
            final boolean publish) {
        if (publish) {
            sendObject(key, item);
        }
        return super.set(key, item, publish);
    }
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