Uses of Class
io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsets
-
-
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()
Gets the offsets for the topic/partitions assigned to thisKafkaStreams
instance. -
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, List<LocalStatePartitionsInfo> stores)
Creates a newKafkaStreamsMetadata
instance. -
Uses of ConsumerGroupOffsets in io.streamthoughts.azkarra.runtime.streams
Methods in io.streamthoughts.azkarra.runtime.streams that return ConsumerGroupOffsets Modifier and Type Method Description ConsumerGroupOffsets
LocalKafkaStreamsContainer. offsets()
Gets the offsets for the topic/partitions assigned to thisKafkaStreams
instance.
-