public ConcurrentKafkaListenerContainerFactory<K, V> getKafkaListenerContainerFactory(final Deserializer<K> keyDeserializer,
                                                                                          final Deserializer<V> valueDeserializer) {
        val listenerContainerFactory = new ConcurrentKafkaListenerContainerFactory<K, V>();
        val consumerFactory = new DefaultKafkaConsumerFactory<>(getConsumerConfiguration(), keyDeserializer, valueDeserializer);
        listenerContainerFactory.setConsumerFactory(consumerFactory);
        return listenerContainerFactory;
    }
Gets kafka listener container factory.

@param keyDeserializer   the key deserializer
@param valueDeserializer the value deserializer
@return the kafka listener container factory
support/cas-server-support-kafka-core/src/main/java/org/apereo/cas/kafka/KafkaObjectFactory.java