Package io.micronaut.configuration.kafka.streams

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.util.Toggleable

@EachProperty(value="kafka.streams",
              primary="default")
@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 io.micronaut.configuration.kafka.config.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 io.micronaut.configuration.kafka.streams.AbstractKafkaStreamsConfiguration

init

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

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