Package io.streamthoughts.azkarra.api.streams.internal

Class InternalStreamsLifecycleContext

java.lang.Object

io.streamthoughts.azkarra.api.streams.internal.InternalStreamsLifecycleContext

All Implemented Interfaces:

StreamsLifecycleContext

public class InternalStreamsLifecycleContext
extends Object
implements StreamsLifecycleContext

Internal StreamsLifecycleContext implementation.

Constructor Summary

Constructors

Constructor	Description
InternalStreamsLifecycleContext(KafkaStreamsContainer container)	Creates a new InternalStreamsLifecycleContext instance.

Method Summary

Modifier and Type	Method	Description
void	addStateChangeWatcher(KafkaStreamsContainer.StateChangeWatcher watcher)	Register a watcher to be notified of KafkaStreams.State change event.
String	applicationId()	Gets application.id of the current streams instance.
KafkaStreamsContainer	container()	Return the container that is running the current KafkaStreams instance.
void	setState(State state)	Sets the state of the current streams instance.
Conf	streamsConfig()	Gets the configuration of the current streams instance.
State	streamsState()	Gets the state value of the current streams instance.
org.apache.kafka.streams.TopologyDescription	topologyDescription()	Gets the TopologyDescription of the current streams instance.
String	topologyName()
Version	topologyVersion()

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalStreamsLifecycleContext

public InternalStreamsLifecycleContext(KafkaStreamsContainer container)

Creates a new InternalStreamsLifecycleContext instance.

Parameters:

container - the KafkaStreamsContainer instance

Method Detail

topologyName

public String topologyName()

Specified by:

topologyName in interface StreamsLifecycleContext

Returns:

the user-specified name for the streams.

topologyVersion

public Version topologyVersion()

Specified by:

topologyVersion in interface StreamsLifecycleContext

Returns:

the version of the streams topology.

applicationId

public String applicationId()

Gets application.id of the current streams instance.

Specified by:

applicationId in interface StreamsLifecycleContext

Returns:

return application.id of the current streams instance.

topologyDescription

public org.apache.kafka.streams.TopologyDescription topologyDescription()

Gets the TopologyDescription of the current streams instance.

Specified by:

topologyDescription in interface StreamsLifecycleContext

Returns:

the TopologyDescription instance; cannot be null.

streamsConfig

public Conf streamsConfig()

Gets the configuration of the current streams instance.

Specified by:

streamsConfig in interface StreamsLifecycleContext

Returns:

the Conf instance; cannot be null.

streamsState

public State streamsState()

Gets the state value of the current streams instance.

Specified by:

streamsState in interface StreamsLifecycleContext

Returns:

the State; cannot be null.

setState

public void setState(State state)

Sets the state of the current streams instance.

Specified by:

setState in interface StreamsLifecycleContext

Parameters:

state - the new State.

addStateChangeWatcher

public void addStateChangeWatcher(KafkaStreamsContainer.StateChangeWatcher watcher)

Register a watcher to be notified of KafkaStreams.State change event.

Specified by:

addStateChangeWatcher in interface StreamsLifecycleContext

Parameters:

watcher - the KafkaStreamsContainer.StateChangeWatcher to be registered.

container

public KafkaStreamsContainer container()

Return the container that is running the current KafkaStreams instance.

Returns:

the KafkaStreamsContainer; cannot be null.