io.micronaut.configuration.kafka.config

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

Type Parameters:

K - The key deserializer type

V - The value deserializer type

@EachProperty(value="kafka.consumers",
              primary="default")
 @Requires(beans=KafkaDefaultConfiguration.class)
public class KafkaConsumerConfiguration<K,V>
extends AbstractKafkaConsumerConfiguration<K,V>

Configuration for Apache Kafka Consumer. See http://kafka.apache.org/documentation/#consumerconfigs

Since:

1.0

Author:

Iván López, Graeme Rocher

Field Summary

Fields

Modifier and Type	Field and Description
static String	PREFIX The default consumers configuration.

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

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED, EMBEDDED_TOPICS

Constructor Summary

Constructors

Constructor and Description
KafkaConsumerConfiguration(String consumerName, KafkaDefaultConfiguration defaultConfiguration, Environment environment) 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

Field Detail

PREFIX

public static final String PREFIX

The default consumers configuration.

See Also:

Constant Field Values

Constructor Detail

KafkaConsumerConfiguration

public KafkaConsumerConfiguration(@Parameter
                                  String consumerName,
                                  KafkaDefaultConfiguration defaultConfiguration,
                                  Environment environment)

Construct a new KafkaConsumerConfiguration for the given defaults.

Parameters:

consumerName - The name of the consumer

defaultConfiguration - The default configuration

environment - The environment