Package io.streamthoughts.azkarra.api.streams.consumer
-
Interface Summary Interface Description ConsumerGroupOffsetsRegistry -
Class Summary Class Description ConsumerClientOffsets ConsumerGroupOffsets ConsumerGroupOffsetsState ConsumerLogOffsets ConsumerThreadKey GlobalConsumerOffsetsRegistry LogOffsetsFetcher MonitorOffsetsConsumerInterceptor<K,V> DefaultConsumerInterceptor
that is used to track consumption progress.OffsetAndTimestamp