io.micronaut.configuration.kafka

Interface ProducerRegistry

All Known Subinterfaces:

KafkaProducerRegistry

All Known Implementing Classes:

KafkaClientScope

public interface ProducerRegistry

A registry of managed Producer instances key by id and type.

Since:

1.0

Author:

graemerocher

Method Summary

Modifier and Type	Method and Description
<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.

Method Detail

getProducer

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

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