io.micronaut.configuration.kafka.config

Class KafkaProducerConfiguration<K,V>

java.lang.Object

io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration<K,V>

io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration<K,V>

io.micronaut.configuration.kafka.config.KafkaProducerConfiguration<K,V>

Type Parameters:

K - The key deserializer type

V - The value deserializer type

@EachProperty(value="kafka.producers",
              primary="default")
 @Requires(beans=KafkaDefaultConfiguration.class)
public class KafkaProducerConfiguration<K,V>
extends AbstractKafkaProducerConfiguration<K,V>

Configuration for Apache Kafka Producer. See http://kafka.apache.org/documentation.html#producerconfigs

Since:

1.0

Author:

Iván López, Graeme Rocher

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	PREFIX The default configuration for producers.

Fields inherited from class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED, EMBEDDED_TOPICS

Constructor Summary

Constructors

Constructor and Description
KafkaProducerConfiguration(java.lang.String producerName, KafkaDefaultConfiguration defaultConfiguration, io.micronaut.context.env.Environment environment) Constructs the default producer configuration.

Method Summary

Methods inherited from class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration

getKeySerializer, getValueSerializer, setKeySerializer, setValueSerializer

Methods inherited from class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration

getConfig

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PREFIX

public static final java.lang.String PREFIX

The default configuration for producers.

See Also:

Constant Field Values

Constructor Detail

KafkaProducerConfiguration

public KafkaProducerConfiguration(@Parameter
                                  java.lang.String producerName,
                                  KafkaDefaultConfiguration defaultConfiguration,
                                  io.micronaut.context.env.Environment environment)

Constructs the default producer configuration.

Parameters:

producerName - The name of the producer

defaultConfiguration - The default Kafka configuration

environment - The environment