Package io.confluent.parallelconsumer.internal
package io.confluent.parallelconsumer.internal
-
ClassDescriptionBrokerPollSystem<K,
V> Subsystem for polling the broker for messages.ConsumerManager<K,V> Delegate forKafkaConsumerCommitter that uses the Kafka Consumer to commit either synchronously or asynchronouslyCommit request messageCommit response message, linked to aConsumerOffsetCommitter.CommitRequestControls a loading factor.EpochAndRecordsMap<K,V> For tagging polled records with our epochExternalEngine<K,V> Overrides key aspects required in common for other threading engines like Vert.x and ReactorGeneric internal runtime errorGeneric Parallel Consumer parent exception.ProducerManager<K,V> The run state of the controller.Single entry point for wrapping the actual execution of user functions