Class KafkaStreamsConfiguration<K,V>

java.lang.Object

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

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

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

Type Parameters:

K - The generic key type

V - The generic value type

All Implemented Interfaces:

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

@EachProperty(value="kafka.streams",
              primary="default")
@ConfigurationProperties("kafka.streams")
@Requires(beans=KafkaDefaultConfiguration.class)
public class KafkaStreamsConfiguration<K,V>
extends AbstractKafkaStreamsConfiguration<K,V>

The default configuration passed to KafkaStreams.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PREFIX	The default streams configuration.

Fields inherited from class AbstractKafkaStreamsConfiguration

DEFAULT_CLOSE_TIMEOUT, DEFAULT_NAME

Fields inherited from class AbstractKafkaConfiguration

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED_TOPICS, TOPICS

Constructor Summary

Constructors

Constructor	Description
KafkaStreamsConfiguration(String streamName, KafkaDefaultConfiguration defaultConfiguration, io.micronaut.runtime.ApplicationConfiguration applicationConfiguration, io.micronaut.context.env.Environment environment)	Construct a new KafkaStreamsConfiguration for the given defaults.

Method Summary

Methods inherited from class AbstractKafkaStreamsConfiguration

getCloseTimeout, getName, init, setCloseTimeout, setName

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

PREFIX

public static final String PREFIX

The default streams configuration.

See Also:

• Constant Field Values

Constructor Details

KafkaStreamsConfiguration

public KafkaStreamsConfiguration(@Parameter
 String streamName,
 KafkaDefaultConfiguration defaultConfiguration,
 io.micronaut.runtime.ApplicationConfiguration applicationConfiguration,
 io.micronaut.context.env.Environment environment)

Construct a new KafkaStreamsConfiguration for the given defaults.

Parameters:

streamName - The stream name

defaultConfiguration - The default configuration

applicationConfiguration - The application configuration

environment - The environment