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

All Implemented Interfaces:

io.micronaut.core.util.Toggleable

@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 https://kafka.apache.org/documentation.html#producerconfigs

Since:

1.0

Author:

Iván López, Graeme Rocher

Field Summary

Fields

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

Fields inherited from class AbstractKafkaConfiguration

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED_TOPICS, TOPICS

Constructor Summary

Constructors

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

Method Summary

Methods inherited from class AbstractKafkaProducerConfiguration

getExecutor, getKeySerializer, getValueSerializer, setExecutor, setKeySerializer, setValueSerializer

Methods inherited from class AbstractKafkaConfiguration

getConfig, toKafkaProperties

Methods inherited from class Object

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

Methods inherited from interface io.micronaut.core.util.Toggleable

isEnabled

Field Details

PREFIX

public static final String PREFIX

The default configuration for producers.

See Also:

• Constant Field Values

Constructor Details

KafkaProducerConfiguration

public KafkaProducerConfiguration(@Parameter
 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