@Test
    void verifyRemoval() {
        val service = RegisteredServiceTestUtils.getRegisteredService();
        val item = new DistributedCacheObject<RegisteredService>(
            Map.of("event", CasRegisteredServiceDeletedEvent.class.getSimpleName()),
            System.currentTimeMillis(),
            service, new PublisherIdentifier());

        assertDoesNotThrow(() -> listener.registeredServiceDistributedCacheKafkaListener(item));
    }
This is {@link RegisteredServiceKafkaDistributedCacheListenerTests}.

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