public KafkaAdmin getKafkaAdmin() {
        val configs = new HashMap<String, Object>();
        configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress);
        val admin = new KafkaAdmin(configs);
        admin.setFatalIfBrokerNotAvailable(true);
        return admin;
    }
Gets kafka admin.

@return the kafka admin
support/cas-server-support-kafka-core/src/main/java/org/apereo/cas/kafka/KafkaObjectFactory.java