io.micronaut.configuration.kafka.config

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

Direct Known Subclasses:

DefaultKafkaConsumerConfiguration, KafkaConsumerConfiguration

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

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

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

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

Method Summary

Modifier and Type	Method and Description
java.util.Optional<org.apache.kafka.common.serialization.Deserializer<K>>	getKeyDeserializer()
java.util.Optional<org.apache.kafka.common.serialization.Deserializer<V>>	getValueDeserializer()
void	setKeyDeserializer(org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer) Sets the key deserializer.
void	setValueDeserializer(org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer) Sets the default value deserializer.

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

AbstractKafkaConsumerConfiguration

protected AbstractKafkaConsumerConfiguration(java.util.Properties config)

Constructs a new instance.

Parameters:

config - The config to use

Method Detail

getKeyDeserializer

public java.util.Optional<org.apache.kafka.common.serialization.Deserializer<K>> getKeyDeserializer()

Returns:

The default key Deserializer

setKeyDeserializer

public void setKeyDeserializer(@Nullable
                               org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer)

Sets the key deserializer.

Parameters:

keyDeserializer - The key serializer

getValueDeserializer

public java.util.Optional<org.apache.kafka.common.serialization.Deserializer<V>> getValueDeserializer()

Returns:

The default value Deserializer

setValueDeserializer

public void setValueDeserializer(@Nullable
                                 org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)

Sets the default value deserializer.

Parameters:

valueDeserializer - The value deserializer