Package io.streamthoughts.azkarra.api
Interface StreamsLifecycleContext
-
public interface StreamsLifecycleContext
Context about the currentKafkaStreams
instance.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default String
applicationId()
KafkaStreamsContainer
container()
void
setState(State state)
Sets the state of the current streams instance.default Conf
streamsConfig()
default State
streamsState()
default org.apache.kafka.streams.TopologyDescription
topologyDescription()
default String
topologyName()
default Version
topologyVersion()
-
-
-
Method Detail
-
applicationId
default String applicationId()
- See Also:
KafkaStreamsContainer.applicationId()
-
topologyDescription
default org.apache.kafka.streams.TopologyDescription topologyDescription()
- See Also:
KafkaStreamsContainer.getTopology()
-
topologyName
default String topologyName()
- See Also:
TopologyMetadata.name()
-
topologyVersion
default Version topologyVersion()
- See Also:
TopologyMetadata.version()
-
streamsConfig
default Conf streamsConfig()
- See Also:
KafkaStreamsContainer.streamsConfig()
-
streamsState
default State streamsState()
- See Also:
KafkaStreamsContainer.state()
-
setState
void setState(State state)
Sets the state of the current streams instance.- Parameters:
state
- the newState
.
-
container
KafkaStreamsContainer container()
- Returns:
- the
KafkaStreamsContainer
; cannot benull
.
-
-