Class DefaultKafkaConsumerConfiguration<K,V>

java.lang.Object

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

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

io.micronaut.configuration.kafka.config.DefaultKafkaConsumerConfiguration<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.consumers.default") @Requires(beans=KafkaDefaultConfiguration.class)
@Primary
@Prototype
public class DefaultKafkaConsumerConfiguration<K,V>
extends AbstractKafkaConsumerConfiguration<K,V>

Default Kafka consumer configuration that comes into play if no other config is specified.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields inherited from class AbstractKafkaConfiguration

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED_TOPICS, PREFIX, TOPICS

Constructor Summary

Constructors

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

Method Summary

Methods inherited from class AbstractKafkaConsumerConfiguration

getKeyDeserializer, getValueDeserializer, setKeyDeserializer, setValueDeserializer

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

DefaultKafkaConsumerConfiguration

@Inject
public DefaultKafkaConsumerConfiguration(KafkaDefaultConfiguration defaultConfiguration)

Construct a new KafkaConsumerConfiguration for the given defaults.

Parameters:

defaultConfiguration - The default configuration

DefaultKafkaConsumerConfiguration

public DefaultKafkaConsumerConfiguration(AbstractKafkaConfiguration defaultConfiguration)

Construct a new KafkaConsumerConfiguration for the given defaults.

Parameters:

defaultConfiguration - The default configuration