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

@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 and Description
static String	PREFIX The default streams configuration.

Fields inherited from class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED, EMBEDDED_TOPICS

Constructor Summary

Constructors

Constructor and Description
KafkaStreamsConfiguration(String streamName, KafkaDefaultConfiguration defaultConfiguration, ApplicationConfiguration applicationConfiguration, 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

Methods inherited from class java.lang.Object

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

Field Detail

PREFIX

public static final String PREFIX

The default streams configuration.

See Also:

Constant Field Values

Constructor Detail

KafkaStreamsConfiguration

public KafkaStreamsConfiguration(@Parameter
                                 String streamName,
                                 KafkaDefaultConfiguration defaultConfiguration,
                                 ApplicationConfiguration applicationConfiguration,
                                 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