Class DefaultKafkaStreamsConfiguration<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.DefaultKafkaStreamsConfiguration<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

@Requires(missingProperty="kafka.streams.default") @Requires(beans=KafkaDefaultConfiguration.class)
@Singleton
@Named("default")
@Primary
public class DefaultKafkaStreamsConfiguration<K,V>
extends AbstractKafkaStreamsConfiguration<K,V>

The default streams configuration if no other is present.

Since:

1.0

Author:

graemerocher

Field Summary

Fields inherited from class AbstractKafkaStreamsConfiguration

DEFAULT_CLOSE_TIMEOUT, DEFAULT_NAME

Fields inherited from class AbstractKafkaConfiguration

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED_TOPICS, PREFIX, TOPICS

Constructor Summary

Constructors

Constructor	Description
DefaultKafkaStreamsConfiguration(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

Constructor Details

DefaultKafkaStreamsConfiguration

public DefaultKafkaStreamsConfiguration(KafkaDefaultConfiguration defaultConfiguration,
 io.micronaut.runtime.ApplicationConfiguration applicationConfiguration,
 io.micronaut.context.env.Environment environment)

Construct a new KafkaStreamsConfiguration for the given defaults.

Parameters:

defaultConfiguration - The default configuration

applicationConfiguration - The application configuration

environment - The environment