Package io.streamthoughts.azkarra.streams.context.internal

Class TopologyConfig

java.lang.Object

io.streamthoughts.azkarra.streams.context.internal.TopologyConfig

public class TopologyConfig
extends Object

Class which is used to configure a TopologyProvider instance.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TopologyConfig.Reader

Field Summary

Fields

Modifier and Type	Field	Description
static String	TOPOLOGY_DESCRIPTION_CONFIG
static String	TOPOLOGY_NAME_CONFIG
static String	TOPOLOGY_PROVIDER_ALIAS_CONFIG
static String	TOPOLOGY_PROVIDER_VERSION_CONFIG
static String	TOPOLOGY_STREAMS_CONFIG

Method Summary

Modifier and Type	Method	Description
Optional<Conf>	config()	Gets the Conf to be used for configuring the TopologyProvider and KafkaStreams instance.
Optional<String>	description()	Gets the user-defined topology description.
Optional<String>	name()	Gets the user-defined topology name.
static TopologyConfig	read(Conf conf)	Static helper that can be used to creates a new TopologyConfig instance from the provided Conf.
String	type()	Gets the TopologyProvider class of alias to be used.
Optional<String>	version()	Gets the TopologyProvider version to be used.

Methods inherited from class java.lang.Object

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

Field Detail

TOPOLOGY_NAME_CONFIG

public static final String TOPOLOGY_NAME_CONFIG

See Also:

Constant Field Values

TOPOLOGY_DESCRIPTION_CONFIG

public static final String TOPOLOGY_DESCRIPTION_CONFIG

See Also:

Constant Field Values

TOPOLOGY_PROVIDER_ALIAS_CONFIG

public static final String TOPOLOGY_PROVIDER_ALIAS_CONFIG

See Also:

Constant Field Values

TOPOLOGY_PROVIDER_VERSION_CONFIG

public static final String TOPOLOGY_PROVIDER_VERSION_CONFIG

See Also:

Constant Field Values

TOPOLOGY_STREAMS_CONFIG

public static final String TOPOLOGY_STREAMS_CONFIG

See Also:

Constant Field Values

Method Detail

read

public static TopologyConfig read(Conf conf)

Static helper that can be used to creates a new TopologyConfig instance from the provided Conf.

Returns:

a new TopologyConfig instance.

type

public String type()

Gets the TopologyProvider class of alias to be used.

Returns:

the type alias. Can return null of the provider is defined using a class name.

name

public Optional<String> name()

Gets the user-defined topology name.

Returns:

the string name.

description

public Optional<String> description()

Gets the user-defined topology description.

Returns:

an optional description.

version

public Optional<String> version()

Gets the TopologyProvider version to be used.

Returns:

an optional version.

config

public Optional<Conf> config()

Gets the Conf to be used for configuring the TopologyProvider and KafkaStreams instance.

Returns:

an optional of Conf.