io.micronaut.configuration.kafka

Interface ProducerFactory

All Known Implementing Classes:

DefaultProducerFactory

public interface ProducerFactory

A factory class for creating Kafka Producer instances.

Since:

5.0.0

Author:

milanspre

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.

Method Detail

createProducer

@NonNull
<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.

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