Index (connect-utils 1.1.0 API)

A B C D E F G H I K M N O P R S T U V W

A

AbstractConverter<T> - Class in com.github.jcustenborder.kafka.connect.utils.data
AbstractConverter() - Constructor for class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
addTemplate(String, String) - Method in class com.github.jcustenborder.kafka.connect.utils.template.StructTemplate
ALWAYS_VISIBLE - Static variable in interface com.github.jcustenborder.kafka.connect.utils.config.recommenders.VisibleCallback
apply(R) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation

B

BaseKeyValueTransformation<R extends org.apache.kafka.connect.connector.ConnectRecord<R>> - Class in com.github.jcustenborder.kafka.connect.utils.transformation
BaseKeyValueTransformation(boolean) - Constructor for class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
batchSize() - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder
batchSize(int) - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder
blankOr(ConfigDef.Validator) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Method will return a validator that will accept a blank string.
build() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
build() - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder
builder(Object) - Static method in class com.github.jcustenborder.kafka.connect.utils.data.SchemaHelper

C

charset(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to return a charset for a string key.
charset() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.recommenders.Recommenders
charset(VisibleCallback) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.recommenders.Recommenders
charset(VisibleCallback, String...) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.recommenders.Recommenders
charset(VisibleCallback, Iterable<String>) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.recommenders.Recommenders
charsets(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to return a charset(s) for a list key.
com.github.jcustenborder.kafka.connect.utils - package com.github.jcustenborder.kafka.connect.utils
com.github.jcustenborder.kafka.connect.utils.config - package com.github.jcustenborder.kafka.connect.utils.config
com.github.jcustenborder.kafka.connect.utils.config.recommenders - package com.github.jcustenborder.kafka.connect.utils.config.recommenders
com.github.jcustenborder.kafka.connect.utils.config.validators - package com.github.jcustenborder.kafka.connect.utils.config.validators
com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem - package com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem
com.github.jcustenborder.kafka.connect.utils.data - package com.github.jcustenborder.kafka.connect.utils.data
com.github.jcustenborder.kafka.connect.utils.template - package com.github.jcustenborder.kafka.connect.utils.template
com.github.jcustenborder.kafka.connect.utils.transformation - package com.github.jcustenborder.kafka.connect.utils.transformation
compare(ConfigDef.ConfigKey, ConfigDef.ConfigKey) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyComparator
compareTo(SchemaKey) - Method in class com.github.jcustenborder.kafka.connect.utils.data.SchemaKey
ConfigKeyBuilder - Class in com.github.jcustenborder.kafka.connect.utils.config
ConfigKeyComparator - Class in com.github.jcustenborder.kafka.connect.utils.config
ConfigKeyComparator() - Constructor for class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyComparator
ConfigUtils - Class in com.github.jcustenborder.kafka.connect.utils.config
ConfigUtils() - Constructor for class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils
convert(Object) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter

D

defaultValue() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
defaultValue(Object) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
dependents() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
dependents(List<String>) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
dependents(String...) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
Description - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
displayName() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
displayName(String) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
documentation() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
documentation(String) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
DocumentationDanger - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
DocumentationImportant - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
DocumentationNote - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
DocumentationSection - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
DocumentationSections - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
DocumentationTip - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
DocumentationWarning - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
drain(List<SourceRecord>) - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordConcurrentLinkedDeque: Method is used to drain the records from the deque in order and add them to the supplied list.
drain(List<SourceRecord>, int) - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordConcurrentLinkedDeque: Method is used to drain the records from the deque in order and add them to the supplied list.
drain() - Method in interface com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDeque: Deprecated.
drain(List<SourceRecord>) - Method in interface com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDeque: Deprecated.
drain(List<SourceRecord>, int) - Method in interface com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDeque: Deprecated.

E

EMPTY - Static variable in interface com.github.jcustenborder.kafka.connect.utils.config.recommenders.ValidValuesCallback
emptyWaitMs() - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder
emptyWaitMs(int) - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder
ensureValid(String, Object, File) - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidDirectory
ensureValid(String, Object, File) - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidDirectoryWritable
ensureValid(String, Object, File) - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidFile
ensureValid(String, Object, File) - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidFileSystem
ensureValid(String, Object) - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidFileSystem
ensureValid(String, Object, File) - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidFileWritable
ensureValid(String, Object) - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.ValidHostAndPort: Deprecated.
ensureValid(String, Object) - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.ValidUrl
ensureValid(String, Object) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ValidEnum: Deprecated.
ensureValid(String, Object) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ValidHostnameAndPort: Deprecated.
ensureValid(String, Object) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ValidPattern: Deprecated.
ensureValid(String, Object) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ValidPort: Deprecated.

Method is used to validate that the supplied port is within the valid range.
ensureWritable - Variable in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidFileSystem
enumDescription(Class<T>, T...) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils
enumDescription(Map<T, String>) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils
enumValues(Class<?>) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to return the values for an enum.
enumValues(Class<?>, String...) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.recommenders.Recommenders
enumValues(Class<?>, VisibleCallback, String...) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.recommenders.Recommenders
equals(Object) - Method in class com.github.jcustenborder.kafka.connect.utils.data.SchemaKey
execute(String, Struct) - Method in class com.github.jcustenborder.kafka.connect.utils.template.StructTemplate
execute(String, Map<String, ?>) - Method in class com.github.jcustenborder.kafka.connect.utils.template.StructTemplate
execute(String, ConnectRecord, Struct, Map<String, ?>) - Method in class com.github.jcustenborder.kafka.connect.utils.template.StructTemplate

F

find(Pattern, String, long) - Static method in class com.github.jcustenborder.kafka.connect.utils.RegexUtils: Executes a matcher().find() operation with timeout protection.

G

getAbsoluteFile(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to return a File checking to ensure that it is an absolute path.
getBatch(int) - Method in interface com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDeque: Method will create a new list based on the batch size and drain records to it.
getBatch() - Method in interface com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDeque: Method will create a new list based on the batch size and drain records to it.
getEnum(Class<T>, AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to return an enum value from a given string.
getEnums(Class<T>, AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to return enums from a list.
getSet(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to retrieve a list and convert it to an immutable set.
getSystemTime() - Static method in class com.github.jcustenborder.kafka.connect.utils.SystemTime
group() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
group(String) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder

H

hashCode() - Method in class com.github.jcustenborder.kafka.connect.utils.data.SchemaKey
hostAndPort(AbstractConfig, String, Integer) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to parse a string ConfigDef item to a HostAndPort
hostAndPort(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to parse a string ConfigDef item to a HostAndPort
hostAndPorts(AbstractConfig, String, Integer) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to parse a list ConfigDef item to a list of HostAndPort
hostAndPorts(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to parse hosts and ports

I

Icon - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
importance() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
importance(ConfigDef.Importance) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
inetSocketAddress(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to return an InetSocketAddress from a hostname:port string.
inetSocketAddresses(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to return a list of InetSocketAddress from a config list of hostname:port strings.
INSTANCE - Static variable in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyComparator
internalConfig(boolean) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
Introduction - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
isinternalConfig() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
isKey - Variable in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation

K

keyManagerFactory(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method will create a KeyManagerFactory based on the Algorithm type specified in the config.
keyStore(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method will create a KeyStore based on the KeyStore type specified in the config.

M

MarkdownFormatter - Class in com.github.jcustenborder.kafka.connect.utils.config
MarkdownFormatter() - Constructor for class com.github.jcustenborder.kafka.connect.utils.config.MarkdownFormatter
matches(Pattern, String, long) - Static method in class com.github.jcustenborder.kafka.connect.utils.RegexUtils: Executes a matcher().matches() operation with timeout protection.
maximumCapacity() - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder
maximumCapacity(int) - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder
maximumCapacityTimeoutMs() - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder
maximumCapacityTimeoutMs(int) - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder
maximumCapacityWaitMs() - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder
maximumCapacityWaitMs(int) - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder
milliseconds() - Method in class com.github.jcustenborder.kafka.connect.utils.SystemTime
multiple(Map<String, String>, int) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.TaskConfigs: Method is used to generate a list of taskConfigs based on the supplied settings.

N

name() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
name - Variable in class com.github.jcustenborder.kafka.connect.utils.data.SchemaKey
nanoseconds() - Method in class com.github.jcustenborder.kafka.connect.utils.SystemTime
newList() - Method in interface com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDeque: Method returns a new list that has an initial capacity of the batch size the deque is configured for.
newValue() - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter

O

of(String, String, ConfigDef.Type) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
of(String, ConfigDef.Type) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
of() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidDirectory
of() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidDirectoryWritable
of() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidFile
of() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidFileWritable
of() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.ValidHostAndPort: Deprecated.
of(Integer, boolean, boolean) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.ValidHostAndPort: Deprecated.
of(Class<?>, String...) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ValidEnum: Deprecated.

Method is used to create a new INSTANCE of the enum validator.
of() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ValidHostnameAndPort: Deprecated.
of(String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ValidPattern: Deprecated.
of(Pattern) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ValidPattern: Deprecated.
of() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ValidPort: Deprecated.

Creates a default INSTANCE of the validator in the non privileged port range of 1025 through 65535.
of(int, int) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ValidPort: Deprecated.

Creates a validator in the port range specified.
of(Schema, String...) - Static method in class com.github.jcustenborder.kafka.connect.utils.data.SchemaBuilders
of(Schema, Collection<String>) - Static method in class com.github.jcustenborder.kafka.connect.utils.data.SchemaBuilders
of(Schema) - Static method in class com.github.jcustenborder.kafka.connect.utils.data.SchemaKey
of() - Static method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder
orderInGroup() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
orderInGroup(int) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder

P

passwordBytes(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to return an array of bytes representing the password stored in the config.
passwordBytes(AbstractConfig, String, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to return an array of bytes representing the password stored in the config.
passwordBytes(AbstractConfig, String, Charset) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to return an array of bytes representing the password stored in the config.
passwordCharArray(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to return an array of characters representing the password stored in the config.
pattern(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to create a pattern based on the config element.
pattern() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Method will return a validator that will ensure that a regular expression properly compiles.
patternMatches(String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Method will return a validator that will validate that a string matches a regular expression
patternMatches(Pattern) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Method will return a validator that will validate that a string matches a regular expression
PluginName - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
PluginOwner - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
process(R, SchemaAndValue) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processArray(R, Schema, List<Object>) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processBoolean(R, Schema, boolean) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processBytes(R, Schema, byte[]) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processDate(R, Schema, Date) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processDecimal(R, Schema, BigDecimal) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processFloat32(R, Schema, float) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processFloat64(R, Schema, double) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processInt16(R, Schema, short) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processInt32(R, Schema, int) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processInt64(R, Schema, long) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processInt8(R, Schema, byte) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processMap(R, Map<String, Object>) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processMap(R, Schema, Map<Object, Object>) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processString(R, Schema, String) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processStruct(R, Schema, Struct) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processTime(R, Schema, Date) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation
processTimestamp(R, Schema, Date) - Method in class com.github.jcustenborder.kafka.connect.utils.transformation.BaseKeyValueTransformation

R

recommender() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
recommender(ConfigDef.Recommender) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
Recommenders - Class in com.github.jcustenborder.kafka.connect.utils.config.recommenders
RegexUtils - Class in com.github.jcustenborder.kafka.connect.utils: Utility class for performing regex operations with timeout protection against ReDoS attacks.
replaceAll(String, Map<Pattern, String>, long) - Static method in class com.github.jcustenborder.kafka.connect.utils.RegexUtils: Executes a matcher().replaceAll(String) operation with timeout protection.

S

schema(Object) - Static method in class com.github.jcustenborder.kafka.connect.utils.data.SchemaHelper
SchemaBuilders - Class in com.github.jcustenborder.kafka.connect.utils.data
SchemaBuilders() - Constructor for class com.github.jcustenborder.kafka.connect.utils.data.SchemaBuilders
SchemaHelper - Class in com.github.jcustenborder.kafka.connect.utils.data
SchemaHelper() - Constructor for class com.github.jcustenborder.kafka.connect.utils.data.SchemaHelper
SchemaKey - Class in com.github.jcustenborder.kafka.connect.utils.data
setArray(T, String, Schema, List) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setBooleanField(T, String, Boolean) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setBytesField(T, String, byte[]) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setDateField(T, String, Date) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setDecimalField(T, String, BigDecimal) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setFloat32Field(T, String, Float) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setFloat64Field(T, String, Double) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setInt16Field(T, String, Short) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setInt32Field(T, String, Integer) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setInt64Field(T, String, Long) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setInt8Field(T, String, Byte) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setMap(T, String, Schema, Map) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setNullField(T, String) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setStringField(T, String, String) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setStructField(T, String, Struct) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setTimeField(T, String, Date) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
setTimestampField(T, String, Date) - Method in class com.github.jcustenborder.kafka.connect.utils.data.AbstractConverter
single(Map<String, String>) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.TaskConfigs: Method will create a single from the supplied settings.
sleep(long) - Method in class com.github.jcustenborder.kafka.connect.utils.SystemTime
SourceRecordConcurrentLinkedDeque - Class in com.github.jcustenborder.kafka.connect.utils.data: Deque used to buffer records from systems using listener threads.
SourceRecordConcurrentLinkedDeque(int, int) - Constructor for class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordConcurrentLinkedDeque: Constructor creates a new INSTANCE of the SourceRecordConcurrentLinkedDeque
SourceRecordConcurrentLinkedDeque() - Constructor for class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordConcurrentLinkedDeque: Constructor creates a new INSTANCE of the SourceRecordConcurrentLinkedDeque with a batchSize of 1024 and timeout of 0.
SourceRecordDeque - Interface in com.github.jcustenborder.kafka.connect.utils.data
SourceRecordDequeBuilder - Class in com.github.jcustenborder.kafka.connect.utils.data
sslContext(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method will create a SSLContext based on the Algorithm type specified in the config.
StructTemplate - Class in com.github.jcustenborder.kafka.connect.utils.template
StructTemplate() - Constructor for class com.github.jcustenborder.kafka.connect.utils.template.StructTemplate
SystemTime - Class in com.github.jcustenborder.kafka.connect.utils

T

TaskConfigs - Class in com.github.jcustenborder.kafka.connect.utils.config
TaskConfigs() - Constructor for class com.github.jcustenborder.kafka.connect.utils.config.TaskConfigs
Title - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
toMarkdown(ConfigDef) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.MarkdownFormatter
toMarkdown(Schema) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.MarkdownFormatter
toString() - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidDirectory
toString() - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidDirectoryWritable
toString() - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidFile
toString() - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidFileWritable
toString() - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.ValidHostAndPort: Deprecated.
toString() - Method in class com.github.jcustenborder.kafka.connect.utils.config.validators.ValidUrl
toString() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ValidEnum: Deprecated.
toString() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ValidPattern: Deprecated.
toString() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ValidPort: Deprecated.
toString() - Method in class com.github.jcustenborder.kafka.connect.utils.data.SchemaKey
TransformationKey - Annotation Type in com.github.jcustenborder.kafka.connect.utils.config
trustManagerFactory(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method will create a TrustManagerFactory based on the Algorithm type specified in the config.
type() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
type - Variable in class com.github.jcustenborder.kafka.connect.utils.data.SchemaKey

U

uri(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to retrieve a URI from a configuration key.
uris(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to retrieve a list of URI(s) from a configuration key.
url(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to retrieve a URL from a configuration key.
urls(AbstractConfig, String) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils: Method is used to retrieve a list of URL(s) from a configuration key.

V

validator() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
validator(ConfigDef.Validator) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
Validators - Class in com.github.jcustenborder.kafka.connect.utils.config.validators
validCharset(String...) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Method will return a validator that will ensure that a String or List contains a charset that is supported by the system.
validCharset() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Method will return a validator that will ensure that a String or List contains a charset that is supported by the system.
ValidDirectory - Class in com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem: Validator is used to ensure that the setting is a directory on the file system and that it is readable.
ValidDirectory(boolean) - Constructor for class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidDirectory
ValidDirectoryWritable - Class in com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem: Validator is used to ensure that the setting is a directory on the file system, is readable, and writable.
validEnum(Class<? extends Enum>, Enum...) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Method is used to create a new INSTANCE of the enum validator.
ValidEnum - Class in com.github.jcustenborder.kafka.connect.utils.config: Deprecated.
ValidFile - Class in com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem: Validator is used to ensure that the setting is a file on the file system and that it is readable.
ValidFile(boolean) - Constructor for class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidFile
ValidFileSystem - Class in com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem: Validator is used as a base for validators that check file system properties.
ValidFileSystem(boolean) - Constructor for class com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem.ValidFileSystem
ValidFileWritable - Class in com.github.jcustenborder.kafka.connect.utils.config.validators.filesystem: Validator is used to ensure that the setting is a file on the file system, is readable, and writable.
validHostAndPort() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Validator to ensure that a configuration setting is a hostname and port.
validHostAndPort(Integer, boolean, boolean) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Validator to ensure that a configuration setting is a hostname and port.
ValidHostAndPort - Class in com.github.jcustenborder.kafka.connect.utils.config.validators: Deprecated.
ValidHostnameAndPort - Class in com.github.jcustenborder.kafka.connect.utils.config: Deprecated.
ValidHostnameAndPort() - Constructor for class com.github.jcustenborder.kafka.connect.utils.config.ValidHostnameAndPort: Deprecated.
validKeyManagerFactory() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Validator is used to ensure that the KeyManagerFactory Algorithm specified is valid.
validKeyStoreType() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Validator is used to ensure that the KeyStore type specified is valid.
ValidPattern - Class in com.github.jcustenborder.kafka.connect.utils.config: Deprecated.
validPort() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Creates a validator in the port range specified.
validPort(int, int) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Creates a validator in the port range specified.
ValidPort - Class in com.github.jcustenborder.kafka.connect.utils.config: Deprecated.
validSSLContext() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Validator is used to ensure that the TrustManagerFactory Algorithm specified is valid.
validTrustManagerFactory() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Validator is used to ensure that the TrustManagerFactory Algorithm specified is valid.
validURI(String...) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Method will return a validator that will ensure that a String or List contains a URI with the proper syntax.
validUrl() - Static method in class com.github.jcustenborder.kafka.connect.utils.config.validators.Validators: Method will return a validator that will ensure that a String or List contains an Url
ValidUrl - Class in com.github.jcustenborder.kafka.connect.utils.config.validators
ValidUrl() - Constructor for class com.github.jcustenborder.kafka.connect.utils.config.validators.ValidUrl
validValues(String, Map<String, Object>) - Method in interface com.github.jcustenborder.kafka.connect.utils.config.recommenders.ValidValuesCallback
ValidValuesCallback - Interface in com.github.jcustenborder.kafka.connect.utils.config.recommenders
version - Variable in class com.github.jcustenborder.kafka.connect.utils.data.SchemaKey
version(Class<?>) - Static method in class com.github.jcustenborder.kafka.connect.utils.VersionUtil
VersionUtil - Class in com.github.jcustenborder.kafka.connect.utils
VersionUtil() - Constructor for class com.github.jcustenborder.kafka.connect.utils.VersionUtil
visible(String, Map<String, Object>) - Method in interface com.github.jcustenborder.kafka.connect.utils.config.recommenders.VisibleCallback
VisibleCallback - Interface in com.github.jcustenborder.kafka.connect.utils.config.recommenders
visibleIf(String, Object) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.recommenders.Recommenders: Method is used to return a recommender that will mark a ConfigItem as visible if the configKey is set to the specified value.
visibleIf(String, Object, ValidValuesCallback) - Static method in class com.github.jcustenborder.kafka.connect.utils.config.recommenders.Recommenders: Method is used to return a recommender that will mark a ConfigItem as visible if the configKey is set to the specified value.

W

waitObject(Object, Supplier<Boolean>, long) - Method in class com.github.jcustenborder.kafka.connect.utils.SystemTime
width() - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
width(ConfigDef.Width) - Method in class com.github.jcustenborder.kafka.connect.utils.config.ConfigKeyBuilder
writeRateLimiter() - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder
writeRateLimiter(RateLimiter) - Method in class com.github.jcustenborder.kafka.connect.utils.data.SourceRecordDequeBuilder

A B C D E F G H I K M N O P R S T U V W