public interface KafkaProducerRegistry
KafkaProducer
instances key by id and type.Modifier and Type | Method and Description |
---|---|
<K,V> KafkaProducer |
getProducer(String id,
Argument<K> keyType,
Argument<V> valueType)
Returns a managed Producer.
|
@Nonnull <K,V> KafkaProducer getProducer(String id, Argument<K> keyType, Argument<V> valueType)
K
- The key generic typeV
- The value generic typeid
- The id of the producer.keyType
- The key typevalueType
- The value type