Uses of Class
io.confluent.parallelconsumer.RecordContext
Packages that use RecordContext
-
Uses of RecordContext in io.confluent.parallelconsumer
Methods in io.confluent.parallelconsumer that return RecordContextModifier and TypeMethodDescriptionRecordContext.RecordContextBuilder.build()RecordContextInternal.getRecordContext()PollContext.getSingleRecord()Must not be using batching (ParallelConsumerOptions.batchSize).PollContextInternal.getSingleRecord()Methods in io.confluent.parallelconsumer that return types with arguments of type RecordContextModifier and TypeMethodDescriptionMap<org.apache.kafka.common.TopicPartition,Set<RecordContext<K, V>>> PollContext.getByTopicPartitionMap()Map<org.apache.kafka.common.TopicPartition,Set<RecordContext<K, V>>> PollContextInternal.getByTopicPartitionMap()List<RecordContext<K,V>> PollContext.getContextsFlattened()List<RecordContext<K,V>> PollContextInternal.getContextsFlattened()ParallelConsumerOptions.getRetryDelayProvider()When present, use this to generate the retry delay, instead ofParallelConsumerOptions.getDefaultMessageRetryDelay().PollContext.iterator()PollContextInternal.iterator()PollContext.spliterator()PollContextInternal.spliterator()PollContext.stream()PollContextInternal.stream()Method parameters in io.confluent.parallelconsumer with type arguments of type RecordContextModifier and TypeMethodDescriptionvoidPollContext.forEach(Consumer<? super RecordContext<K, V>> action) voidPollContextInternal.forEach(Consumer<? super RecordContext<K, V>> action) ParallelConsumerOptions.ParallelConsumerOptionsBuilder.retryDelayProvider(Function<RecordContext<K, V>, Duration> retryDelayProvider) When present, use this to generate the retry delay, instead ofParallelConsumerOptions.getDefaultMessageRetryDelay(). -
Uses of RecordContext in io.confluent.parallelconsumer.state
Constructor parameters in io.confluent.parallelconsumer.state with type arguments of type RecordContextModifierConstructorDescriptionWorkContainer(long epoch, org.apache.kafka.clients.consumer.ConsumerRecord<K, V> cr, Function<RecordContext<K, V>, Duration> retryDelayProvider, String workType, Clock clock) WorkContainer(long epoch, org.apache.kafka.clients.consumer.ConsumerRecord<K, V> cr, Function<RecordContext<K, V>, Duration> retryDelayProvider, Clock clock)