io.micronaut.configuration.kafka

Interface KafkaProducerRegistry

All Known Implementing Classes:

KafkaClientScope

public interface KafkaProducerRegistry

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

Since:

1.0

Author:

graemerocher

Method Summary

Modifier and Type	Method and Description
<K,V> KafkaProducer	getProducer(String id, Argument<K> keyType, Argument<V> valueType) Returns a managed Producer.

Method Detail

getProducer

@Nonnull
<K,V> KafkaProducer getProducer(String id,
                                         Argument<K> keyType,
                                         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