Class KafkaConsumerFactory

java.lang.Object

io.micronaut.configuration.kafka.KafkaConsumerFactory

@Factory
public class KafkaConsumerFactory
extends Object

A factory class for creating Kafka Consumer instances. The consumers are created by the ConsumerFactory bean.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor	Description
KafkaConsumerFactory()	Deprecated, for removal: This API element is subject to removal in a future version. Use KafkaConsumerFactory(ConsumerFactory) instead.
KafkaConsumerFactory(ConsumerFactory consumerFactory)	Creates the factory.

Method Summary

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

Methods inherited from class Object

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

Constructor Details

KafkaConsumerFactory

@Deprecated(since="6.3.0",
            forRemoval=true)
public KafkaConsumerFactory()

Deprecated, for removal: This API element is subject to removal in a future version.

Use KafkaConsumerFactory(ConsumerFactory) instead.

Creates the factory with the DefaultConsumerFactory.

KafkaConsumerFactory

@Inject
public KafkaConsumerFactory(ConsumerFactory consumerFactory)

Creates the factory.

Parameters:

consumerFactory - The consumer factory that creates the Kafka consumers

Since:

6.3.0

Method Details

createConsumer

@Prototype
public <K,V> Consumer<K,V> createConsumer(@Parameter
 AbstractKafkaConsumerConfiguration<K,V> consumerConfiguration)

Creates a new Consumer for the given configuration with the ConsumerFactory.

Type Parameters:

K - The key type

V - The value type

Parameters:

consumerConfiguration - The consumer configuration

Returns:

The consumer