Package io.micronaut.configuration.kafka

Interface ProducerRegistry

All Known Implementing Classes:
KafkaProducerFactory
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
    Description
    <K, V> @NonNull Producer<K,V>
    getProducer(String id, io.micronaut.core.type.Argument<K> keyType, io.micronaut.core.type.Argument<V> valueType)
    Returns a managed Producer.

  • Method Details

    • getProducer

      @NonNull <K, V> @NonNull Producer<K,V> getProducer(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