@Bean
    @RefreshScope(proxyMode = ScopedProxyMode.DEFAULT)
    @ConditionalOnMissingBean(name = "kafkaTicketRegistryPublisher")
    public QueueableTicketRegistryMessagePublisher messageQueueTicketRegistryPublisher(
        final ConfigurableApplicationContext applicationContext,
        @Qualifier(TicketCatalog.BEAN_NAME)
        final TicketCatalog ticketCatalog,
        @Qualifier("messageQueueTicketRegistryIdentifier")
        final PublisherIdentifier messageQueueTicketRegistryIdentifier,
        @Qualifier("kafkaTicketRegistryTemplate")
        final KafkaOperations<String, BaseMessageQueueCommand> kafkaTicketRegistryTemplate) {
        LOGGER.debug("Configuring Kafka ticket registry with identifier [{}]", messageQueueTicketRegistryIdentifier);
        return new KafkaTicketRegistryPublisher(applicationContext, ticketCatalog, kafkaTicketRegistryTemplate);
    }
This is {@link CasKafkaTicketRegistryAutoConfiguration}.

@author Misagh Moayyed
@since 7.2.0
support/cas-server-support-kafka-ticket-registry/src/main/java/org/apereo/cas/config/CasKafkaTicketRegistryAutoConfiguration.java