Uses of Class
io.streamthoughts.azkarra.api.streams.consumer.ConsumerThreadKey

Packages that use ConsumerThreadKey

Package	Description
io.streamthoughts.azkarra.api.streams.consumer

Uses of ConsumerThreadKey in io.streamthoughts.azkarra.api.streams.consumer

Methods in io.streamthoughts.azkarra.api.streams.consumer with parameters of type ConsumerThreadKey

Modifier and Type	Method	Description
void	ConsumerGroupOffsetsState.update(org.apache.kafka.common.TopicPartition tp, ConsumerThreadKey consumerThreadKey, Function<ConsumerLogOffsets,ConsumerLogOffsets> updater)