Class AbstractKafkaConsumerConfiguration<K,V>

java.lang.Object

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

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

Type Parameters:

K - The key deserializer type

V - The value deserializer type

All Implemented Interfaces:

io.micronaut.core.util.Toggleable

Direct Known Subclasses:

DefaultKafkaConsumerConfiguration, KafkaConsumerConfiguration

public abstract class AbstractKafkaConsumerConfiguration<K,V>
extends AbstractKafkaConfiguration<K,V>

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

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

Modifier	Constructor	Description
protected	AbstractKafkaConsumerConfiguration(Properties config)	Constructs a new instance.

Method Summary

Modifier and Type	Method	Description
Optional<Deserializer<K>>	getKeyDeserializer()
Optional<Deserializer<V>>	getValueDeserializer()
void	setKeyDeserializer(@Nullable Deserializer<K> keyDeserializer)	Sets the key deserializer.
void	setValueDeserializer(@Nullable Deserializer<V> valueDeserializer)	Sets the default value deserializer.

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

AbstractKafkaConsumerConfiguration

protected AbstractKafkaConsumerConfiguration(Properties config)

Constructs a new instance.

Parameters:

config - The config to use

Method Details

getKeyDeserializer

public Optional<Deserializer<K>> getKeyDeserializer()

Returns:

The default key Deserializer

setKeyDeserializer

public void setKeyDeserializer(@Nullable Deserializer<K> keyDeserializer)

Sets the key deserializer.

Parameters:

keyDeserializer - The key serializer

getValueDeserializer

public Optional<Deserializer<V>> getValueDeserializer()

Returns:

The default value Deserializer

setValueDeserializer

public void setValueDeserializer(@Nullable Deserializer<V> valueDeserializer)

Sets the default value deserializer.

Parameters:

valueDeserializer - The value deserializer