Uses of Interface
io.confluent.parallelconsumer.internal.OffsetCommitter
Packages that use OffsetCommitter
-
Uses of OffsetCommitter in io.confluent.parallelconsumer.internal
Classes in io.confluent.parallelconsumer.internal that implement OffsetCommitterModifier and TypeClassDescriptionclassclassBrokerPollSystem<K,V> Subsystem for polling the broker for messages.classCommitter that uses the Kafka Consumer to commit either synchronously or asynchronouslyclassProducerManager<K,V>