Uses of Enum Class
io.confluent.parallelconsumer.ParallelConsumerOptions.ProcessingOrder
Packages that use ParallelConsumerOptions.ProcessingOrder
-
Uses of ParallelConsumerOptions.ProcessingOrder in io.confluent.parallelconsumer
Methods in io.confluent.parallelconsumer that return ParallelConsumerOptions.ProcessingOrderModifier and TypeMethodDescriptionParallelConsumerOptions.getOrdering()TheParallelConsumerOptions.ProcessingOrdertype to useReturns the enum constant of this class with the specified name.ParallelConsumerOptions.ProcessingOrder.values()Returns an array containing the constants of this enum class, in the order they are declared.Methods in io.confluent.parallelconsumer with parameters of type ParallelConsumerOptions.ProcessingOrderModifier and TypeMethodDescriptionParallelConsumerOptions.ParallelConsumerOptionsBuilder.ordering(ParallelConsumerOptions.ProcessingOrder ordering) TheParallelConsumerOptions.ProcessingOrdertype to use -
Uses of ParallelConsumerOptions.ProcessingOrder in io.confluent.parallelconsumer.state
Methods in io.confluent.parallelconsumer.state with parameters of type ParallelConsumerOptions.ProcessingOrderModifier and TypeMethodDescriptionstatic ShardKeyShardKey.of(WorkContainer<?, ?> wc, ParallelConsumerOptions.ProcessingOrder ordering) static ShardKeyShardKey.of(org.apache.kafka.clients.consumer.ConsumerRecord<?, ?> rec, ParallelConsumerOptions.ProcessingOrder ordering)