io.micronaut.configuration.kafka.config

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 -

V -

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

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED, EMBEDDED_TOPICS, PREFIX

Constructor Summary

Constructors

Constructor and 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 io.micronaut.configuration.kafka.config.AbstractKafkaConsumerConfiguration

getKeyDeserializer, getValueDeserializer, setKeyDeserializer, setValueDeserializer

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

Constructor Detail

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