@Bean
    @ConditionalOnMissingBean(name = "kafkaListenerContainerFactory")
    public ConcurrentKafkaListenerContainerFactory<String, BaseMessageQueueCommand> kafkaListenerContainerFactory(
        @Qualifier("kafkaTicketRegistryConsumerFactory")
        final ConsumerFactory<String, BaseMessageQueueCommand> kafkaTicketRegistryConsumerFactory) {
        val factory = new ConcurrentKafkaListenerContainerFactory<String, BaseMessageQueueCommand>();
        factory.setConsumerFactory(kafkaTicketRegistryConsumerFactory);
        return factory;
    }
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