io.micronaut.configuration.kafka

Class KafkaProducerFactory

java.lang.Object

io.micronaut.configuration.kafka.KafkaProducerFactory

All Implemented Interfaces:

ProducerRegistry

@Factory
public class KafkaProducerFactory
extends java.lang.Object
implements ProducerRegistry

A factory class for creating Kafka Producer instances.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
KafkaProducerFactory(io.micronaut.context.BeanContext beanContext, SerdeRegistry serdeRegistry) Default constructor.

Method Summary

Modifier and Type	Method and Description
<K,V> org.apache.kafka.clients.producer.Producer<K,V>	getProducer(io.micronaut.inject.InjectionPoint<org.apache.kafka.clients.producer.KafkaProducer<K,V>> injectionPoint, AbstractKafkaProducerConfiguration<K,V> producerConfiguration) Creates a new KafkaProducer for the given configuration.
<K,V> org.apache.kafka.clients.producer.Producer<K,V>	getProducer(java.lang.String id, io.micronaut.core.type.Argument<K> keyType, io.micronaut.core.type.Argument<V> valueType) Returns a managed Producer.
protected void	stop() Shuts down any existing clients.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaProducerFactory

public KafkaProducerFactory(io.micronaut.context.BeanContext beanContext,
                            SerdeRegistry serdeRegistry)

Default constructor.

Parameters:

beanContext - The bean context

serdeRegistry - The serde registry

Method Detail

getProducer

@Bean
 @Any
public <K,V> org.apache.kafka.clients.producer.Producer<K,V> getProducer(@Nullable
                                                                                     io.micronaut.inject.InjectionPoint<org.apache.kafka.clients.producer.KafkaProducer<K,V>> injectionPoint,
                                                                                     @Nullable @Parameter
                                                                                     AbstractKafkaProducerConfiguration<K,V> producerConfiguration)

Creates a new KafkaProducer for the given configuration.

Type Parameters:

K - The key type

V - The value type

Parameters:

injectionPoint - The injection point used to create the bean

producerConfiguration - An optional producer configuration

Returns:

The consumer

stop

@PreDestroy
protected void stop()

Shuts down any existing clients.

getProducer

public <K,V> org.apache.kafka.clients.producer.Producer<K,V> getProducer(java.lang.String id,
                                                                         io.micronaut.core.type.Argument<K> keyType,
                                                                         io.micronaut.core.type.Argument<V> valueType)

Description copied from interface: ProducerRegistry

Returns a managed Producer.

Specified by:

getProducer in interface ProducerRegistry

Type Parameters:

K - The key generic type

V - The value generic type

Parameters:

id - The id of the producer.

keyType - The key type

valueType - The value type

Returns:

The producer