Package io.micronaut.configuration.kafka.streams

Class ConfiguredStreamBuilder

java.lang.Object

org.apache.kafka.streams.StreamsBuilder

io.micronaut.configuration.kafka.streams.ConfiguredStreamBuilder

All Implemented Interfaces:

io.micronaut.core.naming.Named

public class ConfiguredStreamBuilder
extends StreamsBuilder
implements io.micronaut.core.naming.Named

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)	Deprecated. Use ConfiguredStreamBuilder(Properties, String, Duration)
ConfiguredStreamBuilder(Properties configuration, String streamName, Duration closeTimeout)	Default constructor.

Method Summary

Modifier and Type	Method	Description
@NonNull Duration	getCloseTimeout()	The timeout to use when closing the stream.
@NonNull Properties	getConfiguration()	The configuration.
@NonNull String	getName()	The logical name of the stream.

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

addGlobalStore, addGlobalStore, addStateStore, build, build, globalTable, globalTable, globalTable, globalTable, newTopology, 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

@Deprecated(since="5.4.0")
public ConfiguredStreamBuilder(Properties configuration)

Deprecated.

Use ConfiguredStreamBuilder(Properties, String, Duration)

Default constructor.

Parameters:

configuration - The configuration

ConfiguredStreamBuilder

public ConfiguredStreamBuilder(Properties configuration,
 String streamName,
 Duration closeTimeout)

Default constructor.

Parameters:

configuration - The configuration

streamName - The logical name of the stream

closeTimeout - The time to wait for the stream to shut down

Method Details

getConfiguration

@NonNull
public @NonNull Properties getConfiguration()

The configuration. Can be mutated.

Returns:

The configuration

getName

@NonNull
public @NonNull String getName()

The logical name of the stream.

Specified by:

getName in interface io.micronaut.core.naming.Named

Returns:

the logical name of the stream

getCloseTimeout

@NonNull
public @NonNull Duration getCloseTimeout()

The timeout to use when closing the stream.

Returns:

the timeout to use when closing the stream