Uses of Class
io.aiven.commons.kafka.connector.source.config.SourceCommonConfig
Packages that use SourceCommonConfig
Package
Description
-
Uses of SourceCommonConfig in io.aiven.commons.kafka.connector.source
Methods in io.aiven.commons.kafka.connector.source that return SourceCommonConfigModifier and TypeMethodDescriptionprotected abstract SourceCommonConfigAbstractSourceTask.configure(Map<String, String> props, OffsetManager offsetManager) Called byAbstractSourceTask.start(java.util.Map<java.lang.String, java.lang.String>)to allows the concrete implementation to configure itself based on properties.Methods in io.aiven.commons.kafka.connector.source with parameters of type SourceCommonConfigModifier and TypeMethodDescriptionprotected abstract EvolvingSourceRecordIteratorAbstractSourceTask.getIterator(SourceCommonConfig config) Gets the iterator of SourceRecords.Constructors in io.aiven.commons.kafka.connector.source with parameters of type SourceCommonConfigModifierConstructorDescriptionEvolvingSourceRecordIterator(SourceCommonConfig sourceConfig, NativeSourceData<?> nativeSourceData) Constructor.protectedNativeSourceData(SourceCommonConfig sourceConfig, OffsetManager offsetManager) Constructor -
Uses of SourceCommonConfig in io.aiven.commons.kafka.connector.source.config
Methods in io.aiven.commons.kafka.connector.source.config with parameters of type SourceCommonConfigModifier and TypeMethodDescriptionSourceConfigFragment.getExtractor(SourceCommonConfig config) Gets the Extractor instance for this source. -
Uses of SourceCommonConfig in io.aiven.commons.kafka.connector.source.extractor
Fields in io.aiven.commons.kafka.connector.source.extractor declared as SourceCommonConfigModifier and TypeFieldDescriptionprotected final SourceCommonConfigExtractor.configThe source configuration for the Kafka task.Constructors in io.aiven.commons.kafka.connector.source.extractor with parameters of type SourceCommonConfigModifierConstructorDescriptionAvroExtractor(SourceCommonConfig config) Constructs the AvroExtractor.ByteArrayExtractor(SourceCommonConfig config) Constructs a ByteArray extractor using the values from the config.CsvExtractor(SourceCommonConfig config) Constructor.protectedExtractor(SourceCommonConfig config, ExtractorInfo info) Constructor.protectedInputStreamExtractor(SourceCommonConfig config, ExtractorInfo info) Constructs a extractor that processes an input stream rather than a stream of objects.JsonExtractor(SourceCommonConfig config) Constructs the JSON Extractor with the specified config.ParquetExtractor(SourceCommonConfig config) Constructs a ParquetExtractor using the values from the configuration.