Package io.micronaut.configuration.kafka.config

Class AbstractKafkaProducerConfiguration<K,V>

java.lang.Object

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

io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration<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:

DefaultKafkaProducerConfiguration, KafkaProducerConfiguration

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

Abstract Configuration for Apache Kafka Producer. See https://kafka.apache.org/documentation.html#producerconfigs

Since:

1.0

Author:

Iván López, Graeme Rocher

Field Summary

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

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED_TOPICS, PREFIX, TOPICS

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
Optional<String>	getExecutor()
Optional<Serializer<K>>	getKeySerializer()
Optional<Serializer<V>>	getValueSerializer()
void	setExecutor(String executor)	Sets the default executor to use to enable non-blocking producers.
void	setKeySerializer(@Nullable Serializer<K> keySerializer)	Sets the key serializer.
void	setValueSerializer(@Nullable Serializer<V> valueSerializer)	Sets the default value serializer.

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

getConfig, toKafkaProperties

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.core.util.Toggleable

isEnabled

Constructor Details

AbstractKafkaProducerConfiguration

protected AbstractKafkaProducerConfiguration(Properties config)

Constructs a new instance.

Parameters:

config - The config to use

Method Details

getKeySerializer

public Optional<Serializer<K>> getKeySerializer()

Returns:

The default key Serializer

setKeySerializer

public void setKeySerializer(@Nullable
 @Nullable Serializer<K> keySerializer)

Sets the key serializer.

Parameters:

keySerializer - The key serializer

getValueSerializer

public Optional<Serializer<V>> getValueSerializer()

Returns:

The default value Serializer

setValueSerializer

public void setValueSerializer(@Nullable
 @Nullable Serializer<V> valueSerializer)

Sets the default value serializer.

Parameters:

valueSerializer - The value serializer

getExecutor

public Optional<String> getExecutor()

Returns:

The default executor to use to enable non-blocking producers.

setExecutor

public void setExecutor(String executor)

Sets the default executor to use to enable non-blocking producers.

Parameters:

executor - The executor name