Class AbstractKafkaStreamsConfiguration<K,V>

java.lang.Object

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

io.micronaut.configuration.kafka.streams.AbstractKafkaStreamsConfiguration<K,V>

Type Parameters:

K - The key deserializer type

V - The value deserializer type

All Implemented Interfaces:

io.micronaut.core.naming.Named, io.micronaut.core.util.Toggleable

Direct Known Subclasses:

DefaultKafkaStreamsConfiguration, KafkaStreamsConfiguration

public class AbstractKafkaStreamsConfiguration<K,V>
extends AbstractKafkaConfiguration<K,V>
implements io.micronaut.core.naming.Named

Abstract streams configuration.

Since:

1.0

Author:

graemerocher

Field Summary

Fields

Modifier and Type	Field	Description
static final Duration	DEFAULT_CLOSE_TIMEOUT
static final String	DEFAULT_NAME

Fields inherited from class AbstractKafkaConfiguration

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED_TOPICS, PREFIX, TOPICS

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractKafkaStreamsConfiguration(KafkaDefaultConfiguration defaultConfiguration)	Construct a new KafkaStreamsConfiguration for the given defaults.

Method Summary

Modifier and Type	Method	Description
Duration	getCloseTimeout()	The time to wait for the stream to shut down.
@NonNull String	getName()	The logical name of the stream.
protected void	init(io.micronaut.runtime.ApplicationConfiguration applicationConfiguration, io.micronaut.context.env.Environment environment, Properties config)	Shared initialization.
void	setCloseTimeout(Duration closeTimeout)
void	setName(String name)

Methods inherited from class AbstractKafkaConfiguration

getConfig, toKafkaProperties

Methods inherited from class 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_NAME

public static final String DEFAULT_NAME

See Also:

• Constant Field Values

DEFAULT_CLOSE_TIMEOUT

public static final Duration DEFAULT_CLOSE_TIMEOUT

Constructor Details

AbstractKafkaStreamsConfiguration

protected AbstractKafkaStreamsConfiguration(KafkaDefaultConfiguration defaultConfiguration)

Construct a new KafkaStreamsConfiguration for the given defaults.

Parameters:

defaultConfiguration - The default configuration

Method Details

init

protected void init(io.micronaut.runtime.ApplicationConfiguration applicationConfiguration,
 io.micronaut.context.env.Environment environment,
 Properties config)

Shared initialization.

Parameters:

applicationConfiguration - The application config

environment - The env

config - The config to be initialized

getCloseTimeout

public Duration getCloseTimeout()

The time to wait for the stream to shut down. Default value is 3s.

Returns:

the time to wait for the stream to shut down.

setCloseTimeout

public void setCloseTimeout(Duration closeTimeout)

Parameters:

closeTimeout - the time to wait for the stream to shut down

getName

public @NonNull String getName()

The logical name of the stream.

Specified by:

getName in interface io.micronaut.core.naming.Named

Returns:

the logical name of the stream

setName

public void setName(String name)

Parameters:

name - the logical name of the stream