Uses of Class
io.streamthoughts.azkarra.api.model.TimestampedValue
-
-
Uses of TimestampedValue in io.streamthoughts.azkarra.api.model
Methods in io.streamthoughts.azkarra.api.model with parameters of type TimestampedValue Modifier and Type Method Description int
TimestampedValue. compareTo(TimestampedValue that)
-
Uses of TimestampedValue in io.streamthoughts.azkarra.api.streams
Methods in io.streamthoughts.azkarra.api.streams that return TimestampedValue Modifier and Type Method Description TimestampedValue<State>
KafkaStreamsContainer. state()
Gets the current state of the streams container. -
Uses of TimestampedValue in io.streamthoughts.azkarra.runtime.interceptors.monitoring
Constructors in io.streamthoughts.azkarra.runtime.interceptors.monitoring with parameters of type TimestampedValue Constructor Description KafkaStreamsMetadata(TimestampedValue<State> state, Set<org.apache.kafka.streams.processor.ThreadMetadata> threads, ConsumerGroupOffsets offsets, List<LocalStatePartitionsInfo> stores)
Creates a newKafkaStreamsMetadata
instance. -
Uses of TimestampedValue in io.streamthoughts.azkarra.runtime.streams
Methods in io.streamthoughts.azkarra.runtime.streams that return TimestampedValue Modifier and Type Method Description TimestampedValue<State>
LocalKafkaStreamsContainer. state()
Gets the current state of the streams container.
-