Package io.streamthoughts.azkarra.api
Interface StreamsLifecycleContext
-
- All Known Implementing Classes:
KafkaStreamsContainer.InternalStreamsLifeCycleContext
public interface StreamsLifecycleContext
Context about the currentKafkaStreams
instance.
-
-
Method Summary
All Methods Instance Methods Abstract Methods 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.
-
-
-
Method Detail
-
getApplicationId
String getApplicationId()
Gets the application identifier of the current streams instance.- Returns:
- the application id.
-
getTopology
org.apache.kafka.streams.TopologyDescription getTopology()
Gets the topology description of the current streams instance.- Returns:
- the
TopologyDescription
instance.
-
getStreamConfig
Conf getStreamConfig()
Gets the configuration of the current streams instance.- Returns:
- the
Conf
instance.
-
-