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> org.apache.kafka.clients.producer.KafkaProducer	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.KafkaProducer 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