@Bean
    @RefreshScope(proxyMode = ScopedProxyMode.DEFAULT)
    @ConditionalOnMissingBean(name = "kafkaEventRepositoryAdminOperations")
    public KafkaAdminOperations kafkaEventRepositoryAdminOperations(
        final ConfigurableApplicationContext applicationContext,
        final CasConfigurationProperties casProperties) {
        val kafka = casProperties.getEvents().getKafka();
        val factory = new KafkaObjectFactory<String, CasEvent>(kafka.getBootstrapAddress());
        val kafkaAdmin = factory.getKafkaAdmin();
        kafkaAdmin.setAutoCreate(true);
        return kafkaAdmin;
    }
This is {@link CasKafkaEventsAutoConfiguration}.

@author Misagh Moayyed
@since 7.3.0
support/cas-server-support-events-kafka/src/main/java/org/apereo/cas/config/CasKafkaEventsAutoConfiguration.java