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

Direct Known Subclasses:

AbstractKafkaConsumerConfiguration, AbstractKafkaProducerConfiguration, AbstractKafkaStreamsConfiguration, KafkaDefaultConfiguration

public abstract class AbstractKafkaConfiguration<K,V>
extends java.lang.Object

An abstract Kafka configuration class.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_BOOTSTRAP_SERVERS The default bootstrap server address.
static int	DEFAULT_KAFKA_PORT The default kafka port.
static java.lang.String	EMBEDDED The property to use to enable embedded Kafka.
static java.lang.String	EMBEDDED_TOPICS The topics that should be created.
static java.lang.String	PREFIX The default prefix used for Kafka configuration.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
java.util.Properties	getConfig()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_KAFKA_PORT

public static final int DEFAULT_KAFKA_PORT

The default kafka port.

See Also:

Constant Field Values

PREFIX

public static final java.lang.String PREFIX

The default prefix used for Kafka configuration.

See Also:

Constant Field Values

EMBEDDED

public static final java.lang.String EMBEDDED

The property to use to enable embedded Kafka.

See Also:

Constant Field Values

EMBEDDED_TOPICS

public static final java.lang.String EMBEDDED_TOPICS

The topics that should be created.

See Also:

Constant Field Values

DEFAULT_BOOTSTRAP_SERVERS

public static final java.lang.String DEFAULT_BOOTSTRAP_SERVERS

The default bootstrap server address.

See Also:

Constant Field Values

Constructor Detail

AbstractKafkaConfiguration

protected AbstractKafkaConfiguration(java.util.Properties config)

Constructs a new instance.

Parameters:

config - The config to use

Method Detail

getConfig

@Nonnull
public java.util.Properties getConfig()

Returns:

The Kafka configuration