Class DefaultKafkaProducerConfiguration<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.DefaultKafkaProducerConfiguration<K,V>

Type Parameters:

K - The key deserializer type

V - The value deserializer type

All Implemented Interfaces:

io.micronaut.core.util.Toggleable

@Requires(missingProperty="kafka.producers.default") @Requires(beans=KafkaDefaultConfiguration.class)
@Primary
@Prototype
public class DefaultKafkaProducerConfiguration<K,V>
extends AbstractKafkaProducerConfiguration<K,V>

The default KafkaProducer configuration when no default is specified.

Field Summary

Fields inherited from class AbstractKafkaConfiguration

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED_TOPICS, PREFIX, TOPICS

Constructor Summary

Constructors

Constructor	Description
DefaultKafkaProducerConfiguration(AbstractKafkaConfiguration defaultConfiguration)	Construct a new KafkaConsumerConfiguration for the given defaults.
DefaultKafkaProducerConfiguration(KafkaDefaultConfiguration defaultConfiguration)	Constructs a new instance.

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

Constructor Details

DefaultKafkaProducerConfiguration

@Inject
public DefaultKafkaProducerConfiguration(KafkaDefaultConfiguration defaultConfiguration)

Constructs a new instance.

Parameters:

defaultConfiguration - The default Kafka configuration

DefaultKafkaProducerConfiguration

public DefaultKafkaProducerConfiguration(AbstractKafkaConfiguration defaultConfiguration)

Construct a new KafkaConsumerConfiguration for the given defaults.

Parameters:

defaultConfiguration - The default configuration