Uses of Class
io.confluent.parallelconsumer.RecordContextInternal
Packages that use RecordContextInternal
-
Uses of RecordContextInternal in io.confluent.parallelconsumer
Fields in io.confluent.parallelconsumer with type parameters of type RecordContextInternalModifier and TypeFieldDescriptionprotected final Map<org.apache.kafka.common.TopicPartition,Set<RecordContextInternal<K, V>>> PollContext.recordsMethods in io.confluent.parallelconsumer that return types with arguments of type RecordContextInternalModifier and TypeMethodDescriptionPollContext.streamInternal()PollContextInternal.streamInternal()