Uses of Class
io.confluent.parallelconsumer.internal.ConsumerManager

Packages that use ConsumerManager

Package	Description
io.confluent.parallelconsumer.internal

Uses of ConsumerManager in io.confluent.parallelconsumer.internal

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

Modifier and Type	Field	Description
protected final ConsumerManager<K,V>	AbstractOffsetCommitter.consumerMgr

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

Modifier	Constructor	Description
	AbstractOffsetCommitter(ConsumerManager<K,V> consumerMgr, WorkManager<K,V> wm)
	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)
	ProducerManager(org.apache.kafka.clients.producer.Producer<K,V> newProducer, ConsumerManager<K,V> newConsumer, WorkManager<K,V> wm, ParallelConsumerOptions options)