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

All Implemented Interfaces:

io.micronaut.core.util.Toggleable

@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 https://kafka.apache.org/documentation/#consumerconfigs

Since:

1.0

Author:

Iván López, Graeme Rocher

Field Summary

Fields

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

Fields inherited from class AbstractKafkaConfiguration

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED_TOPICS, TOPICS

Constructor Summary

Constructors

Constructor	Description
KafkaConsumerConfiguration(String consumerName, KafkaDefaultConfiguration defaultConfiguration, io.micronaut.context.env.Environment environment)	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

Field Details

PREFIX

public static final String PREFIX

The default consumers configuration.

See Also:

• Constant Field Values

Constructor Details

KafkaConsumerConfiguration

public KafkaConsumerConfiguration(@Parameter
 String consumerName,
 KafkaDefaultConfiguration defaultConfiguration,
 io.micronaut.context.env.Environment environment)

Construct a new KafkaConsumerConfiguration for the given defaults.

Parameters:

consumerName - The name of the consumer

defaultConfiguration - The default configuration

environment - The environment