Class KafkaConsumerFactory

java.lang.Object
io.micronaut.configuration.kafka.KafkaConsumerFactory

@Factory public class KafkaConsumerFactory extends Object
A factory class for creating Kafka Consumer instances.
Since:
1.0
Author:
Graeme Rocher
  • Constructor Details

    • KafkaConsumerFactory

      public KafkaConsumerFactory()
  • Method Details

    • createConsumer

      @Prototype public <K, V> Consumer<K,V> createConsumer(@Parameter AbstractKafkaConsumerConfiguration<K,V> consumerConfiguration)
      Creates a new KafkaConsumer for the given configuration.
      Type Parameters:
      K - The key type
      V - The value type
      Parameters:
      consumerConfiguration - The consumer configuration
      Returns:
      The consumer