Package 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 StreamsBuilder

Extended version of StreamsBuilder that can be configured.

Since:

1.0

Author:

graemerocher

Field Summary

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

internalStreamsBuilder, internalTopologyBuilder, topology

Constructor Summary

Constructors

Constructor	Description
ConfiguredStreamBuilder(Properties configuration)	Default constructor.

Method Summary

Modifier and Type	Method	Description
@NonNull Properties	getConfiguration()	The configuration.

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

addGlobalStore, addGlobalStore, addStateStore, build, build, getNewTopology, 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 Details

ConfiguredStreamBuilder

public ConfiguredStreamBuilder(Properties configuration)

Default constructor.

Parameters:

configuration - The configuration

Method Details

getConfiguration

@NonNull
public @NonNull Properties getConfiguration()

The configuration. Can be mutated.

Returns:

The configuration