Package io.micronaut.configuration.kafka

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 Summary

Constructors

Constructor	Description
KafkaConsumerFactory()

Method Summary

Modifier and Type	Method	Description
<K, V> Consumer<K,V>	createConsumer(AbstractKafkaConsumerConfiguration<K,V> consumerConfiguration)	Creates a new KafkaConsumer for the given configuration.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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