Uses of Interface
io.confluent.parallelconsumer.internal.DrainingCloseable

Packages that use DrainingCloseable

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

Uses of DrainingCloseable in io.confluent.parallelconsumer

Subinterfaces of DrainingCloseable in io.confluent.parallelconsumer

Modifier and Type	Interface	Description
interface	JStreamParallelStreamProcessor<K,V>
interface	ParallelConsumer<K,V>	Asynchronous / concurrent message consumer for Kafka.
interface	ParallelStreamProcessor<K,V>	Parallel message consumer which also can optionally produce 0 or many ProducerRecord results to be published back to Kafka.

Classes in io.confluent.parallelconsumer that implement DrainingCloseable

Modifier and Type	Class	Description
class	JStreamParallelEoSStreamProcessor<K,V>
class	ParallelEoSStreamProcessor<K,V>

Uses of DrainingCloseable in io.confluent.parallelconsumer.internal

Classes in io.confluent.parallelconsumer.internal that implement DrainingCloseable

Modifier and Type	Class	Description
class	AbstractParallelEoSStreamProcessor<K,V>
class	ExternalEngine<K,V>	Overrides key aspects required in common for other threading engines like Vert.x and Reactor