io.micronaut.configuration.kafka.embedded

Class KafkaEmbeddedConfiguration

java.lang.Object

io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration

All Implemented Interfaces:

io.micronaut.core.util.Toggleable

@ConfigurationProperties(value="kafka.embedded")
public class KafkaEmbeddedConfiguration
extends java.lang.Object
implements io.micronaut.core.util.Toggleable

Configuration for the embedded Kafka server.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	DEFAULT_ENABLED The default enable value.
static java.lang.String	PREFIX The prefix used for configuration.

Constructor Summary

Constructors

Constructor and Description
KafkaEmbeddedConfiguration()

Method Summary

Modifier and Type	Method and Description
java.util.Properties	getProperties()
java.util.List<java.lang.String>	getTopics()
boolean	isEnabled()
void	setEnabled(boolean enabled) Sets whether the embedded Kafka server is enabled.
void	setProperties(java.util.Properties properties) Sets the broker properties.
void	setTopics(java.util.List<java.lang.String> topics) The topics that should be created by the embedded instance.

Methods inherited from class java.lang.Object

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

Field Detail

PREFIX

public static final java.lang.String PREFIX

The prefix used for configuration.

See Also:

Constant Field Values

DEFAULT_ENABLED

public static final boolean DEFAULT_ENABLED

The default enable value.

See Also:

Constant Field Values

Constructor Detail

KafkaEmbeddedConfiguration

public KafkaEmbeddedConfiguration()

Method Detail

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface io.micronaut.core.util.Toggleable

setEnabled

public void setEnabled(boolean enabled)

Sets whether the embedded Kafka server is enabled. Default value (false).

Parameters:

enabled - True if it is.

getProperties

@Nonnull
public java.util.Properties getProperties()

Returns:

The broker properties.

setProperties

public void setProperties(java.util.Properties properties)

Sets the broker properties.

Parameters:

properties - The broker properties.

getTopics

public java.util.List<java.lang.String> getTopics()

Returns:

The topics that should be created by the embedded instance

setTopics

public void setTopics(java.util.List<java.lang.String> topics)

The topics that should be created by the embedded instance.

Parameters:

topics - The topic names