io.micronaut.configuration.kafka

Interface KafkaProducerRegistry

All Superinterfaces:

ProducerRegistry

Deprecated.

Use ProducerRegistry instead

@Deprecated
public interface KafkaProducerRegistry
extends ProducerRegistry

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<K,V>	getProducer(java.lang.String id, io.micronaut.core.type.Argument<K> keyType, io.micronaut.core.type.Argument<V> valueType) Deprecated. Returns a managed Producer.

Method Detail

getProducer

@Nonnull
<K,V> org.apache.kafka.clients.producer.KafkaProducer<K,V> getProducer(java.lang.String id,
                                                                                io.micronaut.core.type.Argument<K> keyType,
                                                                                io.micronaut.core.type.Argument<V> valueType)

Deprecated.

Returns a managed Producer.

Specified by:

getProducer in interface ProducerRegistry

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