Uses of Interface
io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer.StateChangeWatcher
-
Packages that use KafkaStreamsContainer.StateChangeWatcher Package Description io.streamthoughts.azkarra.api.streams io.streamthoughts.azkarra.runtime.streams -
-
Uses of KafkaStreamsContainer.StateChangeWatcher in io.streamthoughts.azkarra.api.streams
Methods in io.streamthoughts.azkarra.api.streams with parameters of type KafkaStreamsContainer.StateChangeWatcher Modifier and Type Method Description void
KafkaStreamsContainer. addStateChangeWatcher(KafkaStreamsContainer.StateChangeWatcher watcher)
Register a watcher to be notified ofKafkaStreams.State
change event. -
Uses of KafkaStreamsContainer.StateChangeWatcher in io.streamthoughts.azkarra.runtime.streams
Methods in io.streamthoughts.azkarra.runtime.streams with parameters of type KafkaStreamsContainer.StateChangeWatcher Modifier and Type Method Description void
LocalKafkaStreamsContainer. addStateChangeWatcher(KafkaStreamsContainer.StateChangeWatcher watcher)
Register a watcher to be notified ofKafkaStreams.State
change event.
-