Package io.micronaut.configuration.kafka.streams

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

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

@NonNull
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