Uses of Class
io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsets
-
-
Uses of ConsumerGroupOffsets in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api that return ConsumerGroupOffsets Modifier and Type Method Description ConsumerGroupOffsets
AzkarraStreamsService. getStreamsConsumerOffsetsById(String applicationId)
Gets the topic/partitions offsets for the specified streams application. -
Uses of ConsumerGroupOffsets in io.streamthoughts.azkarra.api.streams
Methods in io.streamthoughts.azkarra.api.streams that return ConsumerGroupOffsets Modifier and Type Method Description ConsumerGroupOffsets
KafkaStreamsContainer. offsets()
-
Uses of ConsumerGroupOffsets in io.streamthoughts.azkarra.api.streams.consumer
Methods in io.streamthoughts.azkarra.api.streams.consumer that return ConsumerGroupOffsets Modifier and Type Method Description ConsumerGroupOffsets
ConsumerGroupOffsetsState. snapshot()
-
Uses of ConsumerGroupOffsets in io.streamthoughts.azkarra.runtime.interceptors.monitoring
Methods in io.streamthoughts.azkarra.runtime.interceptors.monitoring that return ConsumerGroupOffsets Modifier and Type Method Description ConsumerGroupOffsets
KafkaStreamsMetadata. offsets()
Constructors in io.streamthoughts.azkarra.runtime.interceptors.monitoring with parameters of type ConsumerGroupOffsets Constructor Description KafkaStreamsMetadata(TimestampedValue<State> state, Set<org.apache.kafka.streams.processor.ThreadMetadata> threads, ConsumerGroupOffsets offsets)
Creates a newKafkaStreamsMetadata
instance. -
Uses of ConsumerGroupOffsets in io.streamthoughts.azkarra.runtime.service
Methods in io.streamthoughts.azkarra.runtime.service that return ConsumerGroupOffsets Modifier and Type Method Description ConsumerGroupOffsets
LocalAzkarraStreamsService. getStreamsConsumerOffsetsById(String applicationId)
Gets the topic/partitions offsets for the specified streams application.
-