Package io.streamthoughts.azkarra.api

Interface StreamsExecutionEnvironment

All Known Implementing Classes:

DefaultStreamsExecutionEnvironment

public interface StreamsExecutionEnvironment

A StreamsExecutionEnvironment manages the lifecycle of Topology instances.

Field Summary

Fields

Modifier and Type	Field	Description
static String	ENABLE_WAIT_FOR_TOPICS_CONFIG

Method Summary

Modifier and Type	Method	Description
StreamsExecutionEnvironment	addFallbackConfiguration(Conf settings)	Adds streamsConfig that will be used in fallback if not present in defined environment streamsConfig.
StreamsExecutionEnvironment	addGlobalStateListener(org.apache.kafka.streams.processor.StateRestoreListener listener)	Adds a StateRestoreListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
StreamsExecutionEnvironment	addStateListener(org.apache.kafka.streams.KafkaStreams.StateListener listener)	Adds a KafkaStreams.StateListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
ApplicationId	addTopology(Supplier<TopologyProvider> provider)	Add a new TopologyProvider instance to this StreamsExecutionEnvironment to be started.
ApplicationId	addTopology(Supplier<TopologyProvider> provider, Executed executed)	Add a new TopologyProvider instance to this StreamsExecutionEnvironment to be started.
Collection<KafkaStreamsContainer>	applications()	Returns all KafkaStreams started applications.
Conf	getConfiguration()	Gets this environment configuration.
String	name()	Gets the name of this StreamsExecutionEnvironment.
void	remove(ApplicationId id)	Stops the streams instance for the specified application id and remove the associated topology from this environment.
StreamsExecutionEnvironment	setApplicationIdBuilder(Supplier<ApplicationIdBuilder> supplier)	Sets the ApplicationIdBuilder that should be used for building streams application.id.
StreamsExecutionEnvironment	setConfiguration(Conf configuration)	Sets this environment configuration.
StreamsExecutionEnvironment	setRocksDBConfig(RocksDBConfig settings)	Sets the RocksDBConfig streamsConfig used by topology persistent stores.
StreamsExecutionEnvironment	setWaitForTopicsToBeCreated(boolean waitForTopicToBeCreated)	Sets if the streams instances should wait for topics source to be created before starting.
void	start()	Starts this StreamsExecutionEnvironment instance.
State	state()	Gets the state f this StreamsExecutionEnvironment.
default void	stop()	Stops this StreamsExecutionEnvironment instance and all running KafkaStreams instance.
void	stop(boolean cleanUp)	Stops this StreamsExecutionEnvironment instance and all running KafkaStreams instance.
void	stop(ApplicationId id, boolean cleanUp)	Stops the streams instance for the specified application id.

Field Detail

ENABLE_WAIT_FOR_TOPICS_CONFIG

static final String ENABLE_WAIT_FOR_TOPICS_CONFIG

See Also:

Constant Field Values

Method Detail

name

String name()

Gets the name of this StreamsExecutionEnvironment.

Returns:

the string name.

state

State state()

Gets the state f this StreamsExecutionEnvironment.

Returns:

the State.

addStateListener

StreamsExecutionEnvironment addStateListener(org.apache.kafka.streams.KafkaStreams.StateListener listener)

Adds a KafkaStreams.StateListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.

Parameters:

listener - the KafkaStreams.StateListener instance.

Returns:

this StreamsExecutionEnvironment instance.

Throws:

IllegalStateException - if this StreamsExecutionEnvironment instance is started.

addGlobalStateListener

StreamsExecutionEnvironment addGlobalStateListener(org.apache.kafka.streams.processor.StateRestoreListener listener)

Adds a StateRestoreListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.

Parameters:

listener - the StateRestoreListener instance.

Returns:

this StreamsExecutionEnvironment instance.

Throws:

IllegalStateException - if this StreamsExecutionEnvironment instance is started.

See Also:

.

applications

Collection<KafkaStreamsContainer> applications()

Returns all KafkaStreams started applications.

Returns:

a collection of KafkaStreamsContainer applications.

setConfiguration

StreamsExecutionEnvironment setConfiguration(Conf configuration)

Sets this environment configuration.

Returns:

this StreamsExecutionEnvironment instance.

getConfiguration

Conf getConfiguration()

Gets this environment configuration.

Returns:

the Conf instance.

setRocksDBConfig

StreamsExecutionEnvironment setRocksDBConfig(RocksDBConfig settings)

Sets the RocksDBConfig streamsConfig used by topology persistent stores.

Parameters:

settings - the RocksDBConfig instance.

Returns:

this StreamsExecutionEnvironment instance.

setApplicationIdBuilder

StreamsExecutionEnvironment setApplicationIdBuilder(Supplier<ApplicationIdBuilder> supplier)

Sets the ApplicationIdBuilder that should be used for building streams application.id.

Parameters:

supplier - the ApplicationIdBuilder instance supplier.

Returns:

this StreamsExecutionEnvironment instance.

setWaitForTopicsToBeCreated

StreamsExecutionEnvironment setWaitForTopicsToBeCreated(boolean waitForTopicToBeCreated)

Sets if the streams instances should wait for topics source to be created before starting. If some source topics are missing at startup, a streams instance fails.

Parameters:

waitForTopicToBeCreated - should wait for topics to be created.

Returns:

this StreamsExecutionEnvironment instance.

addFallbackConfiguration

StreamsExecutionEnvironment addFallbackConfiguration(Conf settings)

Adds streamsConfig that will be used in fallback if not present in defined environment streamsConfig.

Parameters:

settings - the Conf instance.

Returns:

this StreamsExecutionEnvironment instance.

addTopology

ApplicationId addTopology(Supplier<TopologyProvider> provider)

Add a new TopologyProvider instance to this StreamsExecutionEnvironment to be started.

Parameters:

provider - the TopologyProvider supplier.

Returns:

this ApplicationId instance if the environment is already started, otherwise null.

addTopology

ApplicationId addTopology(Supplier<TopologyProvider> provider,
                          Executed executed)

Add a new TopologyProvider instance to this StreamsExecutionEnvironment to be started.

Parameters:

provider - the TopologyProvider supplier.

executed - the Executed instance.

Returns:

this ApplicationId instance if the environment is already started, otherwise null.

start

void start()

Starts this StreamsExecutionEnvironment instance.

stop

default void stop()

Stops this StreamsExecutionEnvironment instance and all running KafkaStreams instance.

stop

void stop(boolean cleanUp)

Stops this StreamsExecutionEnvironment instance and all running KafkaStreams instance.

Parameters:

cleanUp - if local states of each KafkaStreams instance must be cleanup.

See Also:

.

stop

void stop(ApplicationId id,
          boolean cleanUp)

Stops the streams instance for the specified application id.

Parameters:

id - the ApplicationId of the streams instance.

cleanUp - if local states of each KafkaStreams instance must be cleanup.

See Also:

.

remove

void remove(ApplicationId id)

Stops the streams instance for the specified application id and remove the associated topology from this environment.

Parameters:

id - the ApplicationId of the streams instance.

See Also:

.