Package io.micronaut.configuration.kafka.config

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 io.micronaut.configuration.kafka.config.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 io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration

getExecutor, getKeySerializer, getValueSerializer, setExecutor, setKeySerializer, setValueSerializer

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

getConfig, toKafkaProperties

Methods inherited from class java.lang.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