io.micronaut.configuration.kafka

Class DefaultProducerFactory

java.lang.Object

io.micronaut.configuration.kafka.DefaultProducerFactory

All Implemented Interfaces:

ProducerFactory

@Factory
public class DefaultProducerFactory
extends java.lang.Object
implements ProducerFactory

A default implementation of ProducerFactory used for creating producer.

Since:

5.0.0

Author:

milanspre

Constructor Summary

Constructors

Constructor and Description
DefaultProducerFactory()

Method Summary

Modifier and Type	Method and Description
<K,V> Producer<K,V>	createProducer(java.util.Properties config, Serializer<K> ks, Serializer<V> vs) Creates kafka producer, could be overridden for further control.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultProducerFactory

public DefaultProducerFactory()

Method Detail

createProducer

@NonNull
public <K,V> Producer<K,V> createProducer(java.util.Properties config,
                                                   Serializer<K> ks,
                                                   Serializer<V> vs)

Creates kafka producer, could be overridden for further control.

Specified by:

createProducer in interface ProducerFactory

Type Parameters:

K - key type

V - value type

Parameters:

config - properties for producer

ks - key serializer

vs - value serializer

Returns:

new instance of producer

Since:

5.0.0