Package io.micronaut.configuration.kafka.config

Class AbstractKafkaConfiguration<K,V>

java.lang.Object

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

AbstractKafkaConsumerConfiguration, AbstractKafkaProducerConfiguration, AbstractKafkaStreamsConfiguration, KafkaDefaultConfiguration

public abstract class AbstractKafkaConfiguration<K,V>
extends Object
implements io.micronaut.core.util.Toggleable

An abstract Kafka configuration class.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_BOOTSTRAP_SERVERS	The default bootstrap server address.
static final int	DEFAULT_KAFKA_PORT	The default kafka port.
static final String	EMBEDDED_TOPICS	The topics that should be created.
static final String	PREFIX	The default prefix used for Kafka configuration.
static final String	TOPICS	The topics that should be created.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
@NonNull Properties	getConfig()
protected static Properties	toKafkaProperties(io.micronaut.context.env.Environment environment, Map<?,?> values)	Convert the given map of values to kafka properties.

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

Field Details

DEFAULT_KAFKA_PORT

public static final int DEFAULT_KAFKA_PORT

The default kafka port.

See Also:

• Constant Field Values

PREFIX

public static final String PREFIX

The default prefix used for Kafka configuration.

See Also:

• Constant Field Values

TOPICS

public static final String TOPICS

The topics that should be created.

See Also:

• Constant Field Values

EMBEDDED_TOPICS

public static final String EMBEDDED_TOPICS

The topics that should be created.

See Also:

• Constant Field Values

DEFAULT_BOOTSTRAP_SERVERS

public static final String DEFAULT_BOOTSTRAP_SERVERS

The default bootstrap server address.

See Also:

• Constant Field Values

Constructor Details

AbstractKafkaConfiguration

protected AbstractKafkaConfiguration(Properties config)

Constructs a new instance.

Parameters:

config - The config to use

Method Details

toKafkaProperties

protected static Properties toKafkaProperties(io.micronaut.context.env.Environment environment,
 Map<?,?> values)

Convert the given map of values to kafka properties.

Parameters:

environment - The env

values - The values

Returns:

The kafka properties

getConfig

@NonNull
public @NonNull Properties getConfig()

Returns:

The Kafka configuration