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

Direct Known Subclasses:

DefaultKafkaStreamsConfiguration, KafkaStreamsConfiguration

public class AbstractKafkaStreamsConfiguration<K,V>
extends AbstractKafkaConfiguration<K,V>

Abstract streams configuration.

Since:

1.0

Author:

graemerocher

Field Summary

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

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED, EMBEDDED_TOPICS, PREFIX

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractKafkaStreamsConfiguration(KafkaDefaultConfiguration defaultConfiguration) Construct a new KafkaStreamsConfiguration for the given defaults.

Method Summary

Modifier and Type	Method and Description
protected void	init(ApplicationConfiguration applicationConfiguration, Environment environment, Properties config) Shared initialization.

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

Constructor Detail

AbstractKafkaStreamsConfiguration

protected AbstractKafkaStreamsConfiguration(KafkaDefaultConfiguration defaultConfiguration)

Construct a new KafkaStreamsConfiguration for the given defaults.

Parameters:

defaultConfiguration - The default configuration

Method Detail

init

protected void init(ApplicationConfiguration applicationConfiguration,
                    Environment environment,
                    Properties config)

Shared initialization.

Parameters:

applicationConfiguration - The application config

environment - The env

config - The config to be initialized