Uses of Class
io.confluent.parallelconsumer.ParallelConsumerOptions

Packages that use ParallelConsumerOptions

Package	Description
io.confluent.parallelconsumer
io.confluent.parallelconsumer.internal
io.confluent.parallelconsumer.state

Uses of ParallelConsumerOptions in io.confluent.parallelconsumer

Methods in io.confluent.parallelconsumer that return ParallelConsumerOptions

Modifier and Type	Method	Description
ParallelConsumerOptions<K,V>	ParallelConsumerOptions.ParallelConsumerOptionsBuilder.build()

Methods in io.confluent.parallelconsumer with parameters of type ParallelConsumerOptions

Modifier and Type	Method	Description
static <KK, VV> ParallelStreamProcessor<KK,VV>	ParallelStreamProcessor.createEosStreamProcessor(ParallelConsumerOptions<KK,VV> options)
static JStreamParallelStreamProcessor	JStreamParallelStreamProcessor.createJStreamEosStreamProcessor(ParallelConsumerOptions<?,?> options)

Constructors in io.confluent.parallelconsumer with parameters of type ParallelConsumerOptions

Modifier	Constructor	Description
	JStreamParallelEoSStreamProcessor(ParallelConsumerOptions<K,V> parallelConsumerOptions)
	ParallelEoSStreamProcessor(ParallelConsumerOptions<K,V> newOptions)	Construct the AsyncConsumer by wrapping this passed in consumer and producer, which can be configured any which way as per normal.

Uses of ParallelConsumerOptions in io.confluent.parallelconsumer.internal

Fields in io.confluent.parallelconsumer.internal declared as ParallelConsumerOptions

Modifier and Type	Field	Description
protected final ParallelConsumerOptions	AbstractParallelEoSStreamProcessor.options

Methods in io.confluent.parallelconsumer.internal that return ParallelConsumerOptions

Modifier and Type	Method	Description
protected ParallelConsumerOptions	AbstractParallelEoSStreamProcessor.getOptions()

Constructors in io.confluent.parallelconsumer.internal with parameters of type ParallelConsumerOptions

Modifier	Constructor	Description
	AbstractParallelEoSStreamProcessor(ParallelConsumerOptions<K,V> newOptions)	Construct the AsyncConsumer by wrapping this passed in conusmer and producer, which can be configured any which way as per normal.
	BrokerPollSystem(ConsumerManager<K,V> consumerMgr, WorkManager<K,V> wm, AbstractParallelEoSStreamProcessor<K,V> pc, ParallelConsumerOptions<K,V> options)
	ConsumerOffsetCommitter(ConsumerManager<K,V> newConsumer, WorkManager<K,V> newWorkManager, ParallelConsumerOptions options)
protected	ExternalEngine(ParallelConsumerOptions<K,V> newOptions)
	ProducerManager(org.apache.kafka.clients.producer.Producer<K,V> newProducer, ConsumerManager<K,V> newConsumer, WorkManager<K,V> wm, ParallelConsumerOptions options)

Uses of ParallelConsumerOptions in io.confluent.parallelconsumer.state

Methods in io.confluent.parallelconsumer.state that return ParallelConsumerOptions

Modifier and Type	Method	Description
ParallelConsumerOptions	ShardManager.getOptions()
ParallelConsumerOptions<K,V>	WorkManager.getOptions()

Constructors in io.confluent.parallelconsumer.state with parameters of type ParallelConsumerOptions

Modifier	Constructor	Description
	PartitionStateManager(org.apache.kafka.clients.consumer.Consumer<K,V> consumer, ShardManager<K,V> sm, ParallelConsumerOptions<K,V> options, Clock clock)
	ProcessingShard(ShardKey key, ParallelConsumerOptions<?,?> options, PartitionStateManager<K,V> pm)
	ShardManager(ParallelConsumerOptions options, WorkManager<K,V> wm, Clock clock)
	WorkManager(ParallelConsumerOptions<K,V> options, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
	WorkManager(ParallelConsumerOptions<K,V> newOptions, org.apache.kafka.clients.consumer.Consumer<K,V> consumer, DynamicLoadFactor dynamicExtraLoadFactor, Clock clock)
	WorkManager(ParallelConsumerOptions<K,V> options, org.apache.kafka.clients.consumer.Consumer<K,V> consumer, Clock clock)	Use a private DynamicLoadFactor, useful for testing.