@KafkaListener(topics = "#{registeredServiceDistributedCacheKafkaTopic.name()}",
        groupId = "#{casRegisteredServiceStreamPublisherIdentifier.getId()}",
        containerFactory = "registeredServiceKafkaListenerContainerFactory")
    public void registeredServiceDistributedCacheKafkaListener(
        @Payload
        final DistributedCacheObject<RegisteredService> item) {
        if (!item.getPublisherIdentifier().getId().equals(publisherIdentifier.getId()) && !deleteObjectFromCache(item)) {
            cacheManager.update(item.getValue(), item, false);
        }
    }
Registered service distributed cache kafka listener.

@param item the item
support/cas-server-support-service-registry-stream-kafka/src/main/java/org/apereo/cas/services/RegisteredServiceKafkaDistributedCacheListener.java