io.micronaut.configuration.kafka

Class KafkaProducerFactory

java.lang.Object

io.micronaut.configuration.kafka.KafkaProducerFactory

@Factory
public class KafkaProducerFactory
extends Object

A factory class for creating Kafka Producer instances.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
KafkaProducerFactory()

Method Summary

Modifier and Type	Method and Description
<K,V> KafkaProducer<K,V>	createProducer(AbstractKafkaProducerConfiguration<K,V> producerConfiguration) Creates a new KafkaProducer for the given configuration.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaProducerFactory

public KafkaProducerFactory()

Method Detail

createProducer

@Prototype
public <K,V> KafkaProducer<K,V> createProducer(@Parameter
                                                          AbstractKafkaProducerConfiguration<K,V> producerConfiguration)

Creates a new KafkaProducer for the given configuration.

Type Parameters:

K - The key type

V - The value type

Parameters:

producerConfiguration - The producer configuration

Returns:

The consumer