Package io.aiven.kafka.connect.common.source.task
package io.aiven.kafka.connect.common.source.task
-
ClassDescriptionContext<K extends Comparable<K>>A Context which captures all the details about the source which are required to successfully send a source record onto KafkaAn
DistributionStrategy
provides a mechanism to share the work of processing records from objects (or files) into tasks, which are subsequently processed (potentially in parallel) by Kafka Connect workers.