Package io.streamthoughts.azkarra.api.streams

Class KafkaStreamsContainer.InternalStreamsLifeCycleContext

java.lang.Object

io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer.InternalStreamsLifeCycleContext

All Implemented Interfaces:

StreamsLifecycleContext

Enclosing class:

KafkaStreamsContainer

public class KafkaStreamsContainer.InternalStreamsLifeCycleContext
extends Object
implements StreamsLifecycleContext

Constructor Summary

Constructors

Constructor	Description
InternalStreamsLifeCycleContext()

Method Summary

Modifier and Type	Method	Description
String	getApplicationId()	Gets the application identifier of the current streams instance.
State	getState()	Gets the state of the current streams instance.
Conf	getStreamConfig()	Gets the configuration of the current streams instance.
org.apache.kafka.streams.TopologyDescription	getTopology()	Gets the topology description of the current streams instance.
void	setState(State state)	Sets the state of the current streams instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalStreamsLifeCycleContext

public InternalStreamsLifeCycleContext()

Method Detail

getApplicationId

public String getApplicationId()

Gets the application identifier of the current streams instance.

Specified by:

getApplicationId in interface StreamsLifecycleContext

Returns:

the application id.

getTopology

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

Gets the topology description of the current streams instance.

Specified by:

getTopology in interface StreamsLifecycleContext

Returns:

the TopologyDescription instance.

getStreamConfig

public Conf getStreamConfig()

Gets the configuration of the current streams instance.

Specified by:

getStreamConfig in interface StreamsLifecycleContext

Returns:

the Conf instance.

getState

public State getState()

Gets the state of the current streams instance.

Specified by:

getState in interface StreamsLifecycleContext

Returns:

the State.

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.