io.micronaut.configuration.kafka.streams

Class ConfiguredStreamBuilder

java.lang.Object

org.apache.kafka.streams.StreamsBuilder

io.micronaut.configuration.kafka.streams.ConfiguredStreamBuilder

public class ConfiguredStreamBuilder
extends org.apache.kafka.streams.StreamsBuilder

Extended version of StreamsBuilder that can be configured.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor and Description
ConfiguredStreamBuilder(java.util.Properties configuration) Default constructor.

Method Summary

Modifier and Type	Method and Description
java.util.Properties	getConfiguration() The configuration.

Methods inherited from class org.apache.kafka.streams.StreamsBuilder

addGlobalStore, addGlobalStore, addStateStore, build, build, globalTable, globalTable, globalTable, globalTable, stream, stream, stream, stream, stream, stream, table, table, table, table

Methods inherited from class java.lang.Object

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

Constructor Detail

ConfiguredStreamBuilder

public ConfiguredStreamBuilder(java.util.Properties configuration)

Default constructor.

Parameters:

configuration - The configuration

Method Detail

getConfiguration

@Nonnull
public java.util.Properties getConfiguration()

The configuration. Can be mutated.

Returns:

The configuration