Index (api 7.4.7-ce API)

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

A

abortTransaction() - Method in interface org.apache.kafka.connect.source.TransactionContext: Requests a transaction abort after the next batch of records from SourceTask.poll().
abortTransaction(SourceRecord) - Method in interface org.apache.kafka.connect.source.TransactionContext: Requests a transaction abort after a source record is processed.
AbstractState - Class in org.apache.kafka.connect.health: Provides the current status along with identifier for Connect worker and tasks.
AbstractState(String, String, String) - Constructor for class org.apache.kafka.connect.health.AbstractState: Construct a state for connector or task.
add(Header) - Method in class org.apache.kafka.connect.header.ConnectHeaders
add(String, SchemaAndValue) - Method in class org.apache.kafka.connect.header.ConnectHeaders
add(String, Object, Schema) - Method in class org.apache.kafka.connect.header.ConnectHeaders
add(Header) - Method in interface org.apache.kafka.connect.header.Headers: Add the given Header to this collection.
add(String, SchemaAndValue) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
add(String, Object, Schema) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
addBoolean(String, boolean) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addBoolean(String, boolean) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
addByte(String, byte) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addByte(String, byte) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
addBytes(String, byte[]) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addBytes(String, byte[]) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
addDate(String, Date) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addDate(String, Date) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and Date value.
addDecimal(String, BigDecimal) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addDecimal(String, BigDecimal) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and Decimal value.
addDouble(String, double) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addDouble(String, double) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
addFloat(String, float) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addFloat(String, float) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
addInt(String, int) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addInt(String, int) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
addList(String, List<?>, Schema) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addList(String, List<?>, Schema) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
addLong(String, long) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addLong(String, long) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
addMap(String, Map<?, ?>, Schema) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addMap(String, Map<?, ?>, Schema) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
addShort(String, short) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addShort(String, short) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
addString(String, String) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addString(String, String) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
addStruct(String, Struct) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addStruct(String, Struct) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and value.
addTime(String, Date) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addTime(String, Date) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and Time value.
addTimestamp(String, Date) - Method in class org.apache.kafka.connect.header.ConnectHeaders
addTimestamp(String, Date) - Method in interface org.apache.kafka.connect.header.Headers: Add to this collection a Header with the given key and Timestamp value.
addWithoutValidating(String, Object, Schema) - Method in class org.apache.kafka.connect.header.ConnectHeaders
alignListEntriesWithSchema(Schema, List<Object>) - Static method in class org.apache.kafka.connect.data.Values
alignMapKeysAndValuesWithSchema(Schema, Map<Object, Object>) - Static method in class org.apache.kafka.connect.data.Values
alignMapKeysWithSchema(Schema, Map<Object, Object>) - Static method in class org.apache.kafka.connect.data.Values
allWithName(String) - Method in class org.apache.kafka.connect.header.ConnectHeaders
allWithName(String) - Method in interface org.apache.kafka.connect.header.Headers: Get the collection of Header objects whose keys all match the specified key.
AlreadyExistsException - Exception in org.apache.kafka.connect.errors: Indicates the operation tried to create an entity that already exists.
AlreadyExistsException(String) - Constructor for exception org.apache.kafka.connect.errors.AlreadyExistsException
AlreadyExistsException(String, Throwable) - Constructor for exception org.apache.kafka.connect.errors.AlreadyExistsException
AlreadyExistsException(Throwable) - Constructor for exception org.apache.kafka.connect.errors.AlreadyExistsException
append(StringBuilder, Object, boolean) - Static method in class org.apache.kafka.connect.data.Values
appendIterable(StringBuilder, Iterator<?>) - Static method in class org.apache.kafka.connect.data.Values
apply(String, Headers.HeaderTransform) - Method in class org.apache.kafka.connect.header.ConnectHeaders
apply(Headers.HeaderTransform) - Method in class org.apache.kafka.connect.header.ConnectHeaders
apply(Headers.HeaderTransform) - Method in interface org.apache.kafka.connect.header.Headers: Get all Headers, apply the transform to each and store the result in place of the original.
apply(String, Headers.HeaderTransform) - Method in interface org.apache.kafka.connect.header.Headers: Get all Headers with the given key, apply the transform to each and store the result in place of the original.
apply(Header) - Method in interface org.apache.kafka.connect.header.Headers.HeaderTransform: Transform the given Header and return the updated Header.
apply(R) - Method in interface org.apache.kafka.connect.transforms.Transformation: Apply transformation to the record and return another record object (which may be record itself) or null, corresponding to a map or filter operation respectively.
array(Schema) - Static method in class org.apache.kafka.connect.data.SchemaBuilder
asDouble(Object, Schema, Throwable) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value with the desired floating point type.
asLong(Object, Schema, Throwable) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to the desired scalar value type.
assignment() - Method in interface org.apache.kafka.connect.sink.SinkTaskContext: Get the current set of assigned TopicPartitions for this task.

B

bool() - Static method in class org.apache.kafka.connect.data.SchemaBuilder
BOOLEAN_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
build() - Method in class org.apache.kafka.connect.data.SchemaBuilder: Build the Schema using the current settings
builder() - Static method in class org.apache.kafka.connect.data.Date: Returns a SchemaBuilder for a Date.
builder(int) - Static method in class org.apache.kafka.connect.data.Decimal: Returns a SchemaBuilder for a Decimal with the given scale factor.
builder() - Static method in class org.apache.kafka.connect.data.Time: Returns a SchemaBuilder for a Time.
builder() - Static method in class org.apache.kafka.connect.data.Timestamp: Returns a SchemaBuilder for a Timestamp.
bytes() - Static method in class org.apache.kafka.connect.data.SchemaBuilder
BYTES_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema

C

canConsume(String) - Method in class org.apache.kafka.connect.data.Values.Parser
canConsume(String, boolean) - Method in class org.apache.kafka.connect.data.Values.Parser
canConsumeNextToken() - Method in class org.apache.kafka.connect.data.Values.Parser
canDefineTransactionBoundaries(Map<String, String>) - Method in class org.apache.kafka.connect.source.SourceConnector: Signals whether the connector implementation is capable of defining the transaction boundaries for a connector with the given configuration.
canDetect(Object) - Method in class org.apache.kafka.connect.data.Values.SchemaDetector
canParseSingleTokenLiteral(Values.Parser, boolean, String) - Static method in class org.apache.kafka.connect.data.Values
clear() - Method in class org.apache.kafka.connect.header.ConnectHeaders
clear() - Method in interface org.apache.kafka.connect.header.Headers: Removes all headers from this object.
clientProps() - Method in class org.apache.kafka.connect.connector.policy.ConnectorClientConfigRequest: Provides Config with prefix producer.override. for ConnectorType.SOURCE.
clientType() - Method in class org.apache.kafka.connect.connector.policy.ConnectorClientConfigRequest: ConnectorClientConfigRequest.ClientType.PRODUCER for ConnectorType.SOURCE ConnectorClientConfigRequest.ClientType.CONSUMER for ConnectorType.SINK ConnectorClientConfigRequest.ClientType.PRODUCER for DLQ in ConnectorType.SINK ConnectorClientConfigRequest.ClientType.ADMIN for DLQ Topic Creation in ConnectorType.SINK
close(Collection<TopicPartition>) - Method in class org.apache.kafka.connect.sink.SinkTask: The SinkTask use this method to close writers for partitions that are no longer assigned to the SinkTask.
close() - Method in class org.apache.kafka.connect.storage.SimpleHeaderConverter
close() - Method in class org.apache.kafka.connect.storage.StringConverter
close() - Method in interface org.apache.kafka.connect.transforms.predicates.Predicate
close() - Method in interface org.apache.kafka.connect.transforms.Transformation: Signal that this transformation instance will no longer will be used.
clusterDetails() - Method in interface org.apache.kafka.connect.health.ConnectClusterState: Get details about the setup of the Connect cluster.
clusterState() - Method in interface org.apache.kafka.connect.rest.ConnectRestExtensionContext: Provides the cluster state and health information about the connectors and tasks.
commit() - Method in class org.apache.kafka.connect.source.SourceTask: This method is invoked periodically when offsets are committed for this source task.
commitRecord(SourceRecord) - Method in class org.apache.kafka.connect.source.SourceTask: Deprecated.
Use SourceTask.commitRecord(SourceRecord, RecordMetadata) instead.
commitRecord(SourceRecord, RecordMetadata) - Method in class org.apache.kafka.connect.source.SourceTask: Commit an individual SourceRecord when the callback from the producer client is received.
commitTransaction() - Method in interface org.apache.kafka.connect.source.TransactionContext: Request a transaction commit after the next batch of records from SourceTask.poll() is processed.
commitTransaction(SourceRecord) - Method in interface org.apache.kafka.connect.source.TransactionContext: Request a transaction commit after a source record is processed.
commonSchemaFor(Schema, SchemaAndValue) - Static method in class org.apache.kafka.connect.data.Values
config() - Method in class org.apache.kafka.connect.connector.Connector: Define the configuration for the connector.
config() - Method in interface org.apache.kafka.connect.storage.Converter: Configuration specification for this converter.
config() - Method in interface org.apache.kafka.connect.storage.HeaderConverter: Configuration specification for this set of header converters.
config() - Method in class org.apache.kafka.connect.storage.SimpleHeaderConverter
config() - Method in class org.apache.kafka.connect.storage.StringConverter
config() - Method in interface org.apache.kafka.connect.transforms.predicates.Predicate: Configuration specification for this predicate.
config() - Method in interface org.apache.kafka.connect.transforms.Transformation: Configuration specification for this transformation.
configDef() - Static method in class org.apache.kafka.connect.storage.StringConverterConfig
configs() - Method in interface org.apache.kafka.connect.sink.SinkTaskContext: Get the Task configuration.
configs() - Method in interface org.apache.kafka.connect.source.SourceTaskContext: Get the Task configuration.
configurable() - Method in interface org.apache.kafka.connect.rest.ConnectRestExtensionContext: Provides an implementation of Configurable that be used to register JAX-RS resources.
configure(Map<String, ?>, boolean) - Method in interface org.apache.kafka.connect.storage.Converter: Configure this class.
configure(Map<String, ?>) - Method in class org.apache.kafka.connect.storage.SimpleHeaderConverter
configure(Map<String, ?>) - Method in class org.apache.kafka.connect.storage.StringConverter
configure(Map<String, ?>, boolean) - Method in class org.apache.kafka.connect.storage.StringConverter
ConnectClusterDetails - Interface in org.apache.kafka.connect.health: Provides immutable Connect cluster information, such as the ID of the backing Kafka cluster.
ConnectClusterState - Interface in org.apache.kafka.connect.health: Provides the ability to lookup connector metadata, including status and configurations, as well as immutable cluster information such as Kafka cluster ID.
ConnectException - Exception in org.apache.kafka.connect.errors: ConnectException is the top-level exception type generated by Kafka Connect and connector implementations.
ConnectException(String) - Constructor for exception org.apache.kafka.connect.errors.ConnectException
ConnectException(String, Throwable) - Constructor for exception org.apache.kafka.connect.errors.ConnectException
ConnectException(Throwable) - Constructor for exception org.apache.kafka.connect.errors.ConnectException
ConnectHeaders - Class in org.apache.kafka.connect.header: A basic Headers implementation.
ConnectHeaders() - Constructor for class org.apache.kafka.connect.header.ConnectHeaders
ConnectHeaders(Iterable<Header>) - Constructor for class org.apache.kafka.connect.header.ConnectHeaders
Connector - Class in org.apache.kafka.connect.connector: Connectors manage integration of Kafka Connect with another system, either as an input that ingests data into Kafka or an output that passes data to an external system.
Connector() - Constructor for class org.apache.kafka.connect.connector.Connector
connectorClass() - Method in class org.apache.kafka.connect.connector.policy.ConnectorClientConfigRequest: The class of the Connector.
ConnectorClientConfigOverridePolicy - Interface in org.apache.kafka.connect.connector.policy: An interface for enforcing a policy on overriding of client configs via the connector configs.
ConnectorClientConfigRequest - Class in org.apache.kafka.connect.connector.policy
ConnectorClientConfigRequest(String, ConnectorType, Class<? extends Connector>, Map<String, Object>, ConnectorClientConfigRequest.ClientType) - Constructor for class org.apache.kafka.connect.connector.policy.ConnectorClientConfigRequest
ConnectorClientConfigRequest.ClientType - Enum in org.apache.kafka.connect.connector.policy
connectorConfig(String) - Method in interface org.apache.kafka.connect.health.ConnectClusterState: Lookup the current configuration of a connector.
ConnectorContext - Interface in org.apache.kafka.connect.connector: ConnectorContext allows Connectors to proactively interact with the Kafka Connect runtime.
connectorHealth(String) - Method in interface org.apache.kafka.connect.health.ConnectClusterState: Lookup the current health of a connector and its tasks.
ConnectorHealth - Class in org.apache.kafka.connect.health: Provides basic health information about the connector and its tasks.
ConnectorHealth(String, ConnectorState, Map<Integer, TaskState>, ConnectorType) - Constructor for class org.apache.kafka.connect.health.ConnectorHealth
connectorName() - Method in class org.apache.kafka.connect.connector.policy.ConnectorClientConfigRequest: Name of the connector specified in the connector config.
connectors() - Method in interface org.apache.kafka.connect.health.ConnectClusterState: Get the names of the connectors currently deployed in this cluster.
connectorState() - Method in class org.apache.kafka.connect.health.ConnectorHealth: Provides the current state of the connector.
ConnectorState - Class in org.apache.kafka.connect.health: Describes the status, worker ID, and any errors associated with a connector.
ConnectorState(String, String, String) - Constructor for class org.apache.kafka.connect.health.ConnectorState: Provides an instance of the ConnectorState.
ConnectorTransactionBoundaries - Enum in org.apache.kafka.connect.source: An enum to represent the level of support for connector-defined transaction boundaries.
connectorType() - Method in class org.apache.kafka.connect.connector.policy.ConnectorClientConfigRequest: Type of the Connector.
ConnectorType - Enum in org.apache.kafka.connect.health: Enum definition that identifies the type of the connector.
ConnectorUtils - Class in org.apache.kafka.connect.util: Utilities that connector implementations might find useful.
ConnectorUtils() - Constructor for class org.apache.kafka.connect.util.ConnectorUtils
ConnectRecord<R extends ConnectRecord<R>> - Class in org.apache.kafka.connect.connector: Base class for records containing data to be copied to/from Kafka.
ConnectRecord(String, Integer, Schema, Object, Schema, Object, Long) - Constructor for class org.apache.kafka.connect.connector.ConnectRecord
ConnectRecord(String, Integer, Schema, Object, Schema, Object, Long, Iterable<Header>) - Constructor for class org.apache.kafka.connect.connector.ConnectRecord
ConnectRestExtension - Interface in org.apache.kafka.connect.rest: A plugin interface to allow registration of new JAX-RS resources like Filters, REST endpoints, providers, etc.
ConnectRestExtensionContext - Interface in org.apache.kafka.connect.rest: The interface provides the ability for ConnectRestExtension implementations to access the JAX-RS Configurable and cluster state ConnectClusterState.
ConnectSchema - Class in org.apache.kafka.connect.data
ConnectSchema(Schema.Type, boolean, Object, String, Integer, String, Map<String, String>, List<Field>, Schema, Schema) - Constructor for class org.apache.kafka.connect.data.ConnectSchema: Construct a Schema.
ConnectSchema(Schema.Type, boolean, Object, String, Integer, String) - Constructor for class org.apache.kafka.connect.data.ConnectSchema: Construct a Schema for a primitive type, setting schema parameters, struct fields, and key and value schemas to null.
ConnectSchema(Schema.Type) - Constructor for class org.apache.kafka.connect.data.ConnectSchema: Construct a default schema for a primitive type.
context - Variable in class org.apache.kafka.connect.connector.Connector
context() - Method in class org.apache.kafka.connect.connector.Connector: Returns the context object used to interact with the Kafka Connect runtime.
context() - Method in class org.apache.kafka.connect.sink.SinkConnector
context - Variable in class org.apache.kafka.connect.sink.SinkTask
context() - Method in class org.apache.kafka.connect.source.SourceConnector
context - Variable in class org.apache.kafka.connect.source.SourceTask
Converter - Interface in org.apache.kafka.connect.storage: The Converter interface provides support for translating between Kafka Connect's runtime data format and byte[].
ConverterConfig - Class in org.apache.kafka.connect.storage: Abstract class that defines the configuration options for Converter and HeaderConverter instances.
ConverterConfig(ConfigDef, Map<String, ?>) - Constructor for class org.apache.kafka.connect.storage.ConverterConfig
ConverterType - Enum in org.apache.kafka.connect.storage: The type of Converter and HeaderConverter.
convertTo(Schema, Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the value to the desired type.
convertToBoolean(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an Schema.Type.BOOLEAN value.
convertToByte(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an Schema.Type.INT8 byte value.
convertToDate(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an date value.
convertToDecimal(Schema, Object, int) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an decimal value.
convertToDouble(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an Schema.Type.FLOAT64 double value.
convertToFloat(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an Schema.Type.FLOAT32 float value.
convertToInteger(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an Schema.Type.INT32 int value.
convertToList(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an Schema.Type.ARRAY value.
convertToLong(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an Schema.Type.INT64 long value.
convertToMap(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an Schema.Type.MAP value.
convertToShort(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an Schema.Type.INT16 short value.
convertToString(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an Schema.Type.STRING value.
convertToStruct(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an Schema.Type.STRUCT value.
convertToTime(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an time value.
convertToTimestamp(Schema, Object) - Static method in class org.apache.kafka.connect.data.Values: Convert the specified value to an timestamp value.

D

DataException - Exception in org.apache.kafka.connect.errors: Base class for all Kafka Connect data API exceptions.
DataException(String) - Constructor for exception org.apache.kafka.connect.errors.DataException
DataException(String, Throwable) - Constructor for exception org.apache.kafka.connect.errors.DataException
DataException(Throwable) - Constructor for exception org.apache.kafka.connect.errors.DataException
Date - Class in org.apache.kafka.connect.data: A date representing a calendar day with no time of day or timezone.
Date() - Constructor for class org.apache.kafka.connect.data.Date
dateFormatFor(Date) - Static method in class org.apache.kafka.connect.data.Values
Decimal - Class in org.apache.kafka.connect.data: An arbitrary-precision signed decimal number.
Decimal() - Constructor for class org.apache.kafka.connect.data.Decimal
DEFAULT - Static variable in enum org.apache.kafka.connect.source.SourceTask.TransactionBoundary: The default transaction boundary style that will be used for source connectors when no style is explicitly configured.
defaultValue() - Method in class org.apache.kafka.connect.data.ConnectSchema
defaultValue() - Method in interface org.apache.kafka.connect.data.Schema
defaultValue() - Method in class org.apache.kafka.connect.data.SchemaBuilder
defaultValue(Object) - Method in class org.apache.kafka.connect.data.SchemaBuilder: Set the default value for this schema.
doc() - Method in class org.apache.kafka.connect.data.ConnectSchema
doc() - Method in interface org.apache.kafka.connect.data.Schema
doc() - Method in class org.apache.kafka.connect.data.SchemaBuilder
doc(String) - Method in class org.apache.kafka.connect.data.SchemaBuilder: Set the documentation for this schema.
duplicate() - Method in class org.apache.kafka.connect.header.ConnectHeaders
duplicate() - Method in interface org.apache.kafka.connect.header.Headers: Create a copy of this Headers object.

E

encoding() - Method in class org.apache.kafka.connect.storage.StringConverterConfig: Get the string encoding.
ENCODING_CONFIG - Static variable in class org.apache.kafka.connect.storage.StringConverterConfig
ENCODING_DEFAULT - Static variable in class org.apache.kafka.connect.storage.StringConverterConfig
equals(Object) - Method in class org.apache.kafka.connect.connector.ConnectRecord
equals(Object) - Method in class org.apache.kafka.connect.data.ConnectSchema
equals(Object) - Method in class org.apache.kafka.connect.data.Field
equals(Object) - Method in class org.apache.kafka.connect.data.SchemaAndValue
equals(Object) - Method in class org.apache.kafka.connect.data.Struct
equals(Object) - Method in class org.apache.kafka.connect.header.ConnectHeaders
equals(Object) - Method in class org.apache.kafka.connect.health.AbstractState
equals(Object) - Method in class org.apache.kafka.connect.health.ConnectorHealth
equals(Object) - Method in class org.apache.kafka.connect.health.TaskState
equals(Object) - Method in class org.apache.kafka.connect.sink.SinkRecord
equals(Object) - Method in class org.apache.kafka.connect.source.SourceRecord
ErrantRecordReporter - Interface in org.apache.kafka.connect.sink: Component that the sink task can use as it SinkTask.put(java.util.Collection).
errantRecordReporter() - Method in interface org.apache.kafka.connect.sink.SinkTaskContext: Get the reporter to which the sink task can report problematic or failed records passed to the SinkTask.put(java.util.Collection) method.
escape(String) - Static method in class org.apache.kafka.connect.data.Values
ExactlyOnceSupport - Enum in org.apache.kafka.connect.source: An enum to represent the level of support for exactly-once semantics from a source connector.
exactlyOnceSupport(Map<String, String>) - Method in class org.apache.kafka.connect.source.SourceConnector: Signals whether the connector supports exactly-once semantics with a proposed configuration.

F

field(String) - Method in class org.apache.kafka.connect.data.ConnectSchema
Field - Class in org.apache.kafka.connect.data: A field in a Struct, consisting of a field name, index, and Schema for the field value.
Field(String, int, Schema) - Constructor for class org.apache.kafka.connect.data.Field
field(String) - Method in interface org.apache.kafka.connect.data.Schema: Get a field for this Schema by name.
field(String, Schema) - Method in class org.apache.kafka.connect.data.SchemaBuilder: Add a field to this struct schema.
field(String) - Method in class org.apache.kafka.connect.data.SchemaBuilder
fields() - Method in class org.apache.kafka.connect.data.ConnectSchema
fields() - Method in interface org.apache.kafka.connect.data.Schema: Get the list of fields for this Schema.
fields() - Method in class org.apache.kafka.connect.data.SchemaBuilder: Get the list of fields for this Schema.
float32() - Static method in class org.apache.kafka.connect.data.SchemaBuilder
FLOAT32_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
float64() - Static method in class org.apache.kafka.connect.data.SchemaBuilder
FLOAT64_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
flush(Map<TopicPartition, OffsetAndMetadata>) - Method in class org.apache.kafka.connect.sink.SinkTask: Flush all records that have been SinkTask.put(Collection) for the specified topic-partitions.
fromConnectData(String, Schema, Object) - Method in interface org.apache.kafka.connect.storage.Converter: Convert a Kafka Connect data object to a native object for serialization.
fromConnectData(String, Headers, Schema, Object) - Method in interface org.apache.kafka.connect.storage.Converter: Convert a Kafka Connect data object to a native object for serialization, potentially using the supplied topic and headers in the record as necessary.
fromConnectData(String, Schema, Object) - Method in class org.apache.kafka.connect.storage.StringConverter
fromConnectHeader(String, String, Schema, Object) - Method in interface org.apache.kafka.connect.storage.HeaderConverter: Convert the Header's value into its byte array representation.
fromConnectHeader(String, String, Schema, Object) - Method in class org.apache.kafka.connect.storage.SimpleHeaderConverter
fromConnectHeader(String, String, Schema, Object) - Method in class org.apache.kafka.connect.storage.StringConverter
fromLogical(Schema, Date) - Static method in class org.apache.kafka.connect.data.Date: Convert a value from its logical format (Date) to it's encoded format.
fromLogical(Schema, BigDecimal) - Static method in class org.apache.kafka.connect.data.Decimal: Convert a value from its logical format (BigDecimal) to it's encoded format.
fromLogical(Schema, Date) - Static method in class org.apache.kafka.connect.data.Time: Convert a value from its logical format (Time) to it's encoded format.
fromLogical(Schema, Date) - Static method in class org.apache.kafka.connect.data.Timestamp: Convert a value from its logical format (Date) to it's encoded format.
fromProperty(String) - Static method in enum org.apache.kafka.connect.source.SourceTask.TransactionBoundary: Parse a SourceTask.TransactionBoundary from the given string.

G

get(String) - Method in class org.apache.kafka.connect.data.Struct: Get the value of a field, returning the default value if no value has been set yet and a default value is specified in the field's schema.
get(Field) - Method in class org.apache.kafka.connect.data.Struct: Get the value of a field, returning the default value if no value has been set yet and a default value is specified in the field's schema.
getArray(String) - Method in class org.apache.kafka.connect.data.Struct: Equivalent to calling Struct.get(String) and casting the result to a List.
getBoolean(String) - Method in class org.apache.kafka.connect.data.Struct: Equivalent to calling Struct.get(String) and casting the result to a Boolean.
getBytes(String) - Method in class org.apache.kafka.connect.data.Struct: Equivalent to calling Struct.get(String) and casting the result to a byte[].
getFloat32(String) - Method in class org.apache.kafka.connect.data.Struct: Equivalent to calling Struct.get(String) and casting the result to a Float.
getFloat64(String) - Method in class org.apache.kafka.connect.data.Struct: Equivalent to calling Struct.get(String) and casting the result to a Double.
getInt16(String) - Method in class org.apache.kafka.connect.data.Struct: Equivalent to calling Struct.get(String) and casting the result to a Short.
getInt32(String) - Method in class org.apache.kafka.connect.data.Struct: Equivalent to calling Struct.get(String) and casting the result to a Integer.
getInt64(String) - Method in class org.apache.kafka.connect.data.Struct: Equivalent to calling Struct.get(String) and casting the result to a Long.
getInt8(String) - Method in class org.apache.kafka.connect.data.Struct: Equivalent to calling Struct.get(String) and casting the result to a Byte.
getMap(String) - Method in class org.apache.kafka.connect.data.Struct: Equivalent to calling Struct.get(String) and casting the result to a Map.
getName() - Method in enum org.apache.kafka.connect.data.Schema.Type
getName() - Method in enum org.apache.kafka.connect.storage.ConverterType
getString(String) - Method in class org.apache.kafka.connect.data.Struct: Equivalent to calling Struct.get(String) and casting the result to a String.
getStruct(String) - Method in class org.apache.kafka.connect.data.Struct: Equivalent to calling Struct.get(String) and casting the result to a Struct.
getWithoutDefault(String) - Method in class org.apache.kafka.connect.data.Struct: Get the underlying raw value for the field without accounting for default values.
groupPartitions(List<T>, int) - Static method in class org.apache.kafka.connect.util.ConnectorUtils: Given a list of elements and a target number of groups, generates list of groups of elements to match the target number of groups, spreading them evenly among the groups.

H

hashCode() - Method in class org.apache.kafka.connect.connector.ConnectRecord
hashCode() - Method in class org.apache.kafka.connect.data.ConnectSchema
hashCode() - Method in class org.apache.kafka.connect.data.Field
hashCode() - Method in class org.apache.kafka.connect.data.SchemaAndValue
hashCode() - Method in class org.apache.kafka.connect.data.Struct
hashCode() - Method in class org.apache.kafka.connect.header.ConnectHeaders
hashCode() - Method in class org.apache.kafka.connect.health.AbstractState
hashCode() - Method in class org.apache.kafka.connect.health.ConnectorHealth
hashCode() - Method in class org.apache.kafka.connect.health.TaskState
hashCode() - Method in class org.apache.kafka.connect.sink.SinkRecord
hashCode() - Method in class org.apache.kafka.connect.source.SourceRecord
hasNext() - Method in class org.apache.kafka.connect.data.Values.Parser
Header - Interface in org.apache.kafka.connect.header: A Header is a key-value pair, and multiple headers can be included with the key, value, and timestamp in each Kafka message.
HeaderConverter - Interface in org.apache.kafka.connect.storage
headers() - Method in class org.apache.kafka.connect.connector.ConnectRecord: Get the headers for this record.
Headers - Interface in org.apache.kafka.connect.header: A mutable ordered collection of Header objects.
Headers.HeaderTransform - Interface in org.apache.kafka.connect.header: A function to transform the supplied Header.

I

IllegalWorkerStateException - Exception in org.apache.kafka.connect.errors: Indicates that a method has been invoked illegally or at an invalid time by a connector or task.
IllegalWorkerStateException(String) - Constructor for exception org.apache.kafka.connect.errors.IllegalWorkerStateException
IllegalWorkerStateException(String, Throwable) - Constructor for exception org.apache.kafka.connect.errors.IllegalWorkerStateException
IllegalWorkerStateException(Throwable) - Constructor for exception org.apache.kafka.connect.errors.IllegalWorkerStateException
index() - Method in class org.apache.kafka.connect.data.Field: Get the index of this field within the struct.
inferSchema(Object) - Static method in class org.apache.kafka.connect.data.Values: If possible infer a schema for the given value.
initialize(ConnectorContext) - Method in class org.apache.kafka.connect.connector.Connector: Initialize this connector, using the provided ConnectorContext to notify the runtime of input configuration changes.
initialize(ConnectorContext, List<Map<String, String>>) - Method in class org.apache.kafka.connect.connector.Connector: Initialize this connector, using the provided ConnectorContext to notify the runtime of input configuration changes and using the provided set of Task configurations.
initialize(SinkTaskContext) - Method in class org.apache.kafka.connect.sink.SinkTask: Initialize the context of this task.
initialize(SourceTaskContext) - Method in class org.apache.kafka.connect.source.SourceTask: Initialize this SourceTask with the specified context object.
int16() - Static method in class org.apache.kafka.connect.data.SchemaBuilder
INT16_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
int32() - Static method in class org.apache.kafka.connect.data.SchemaBuilder
INT32_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
int64() - Static method in class org.apache.kafka.connect.data.SchemaBuilder
INT64_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
int8() - Static method in class org.apache.kafka.connect.data.SchemaBuilder
INT8_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
isEmpty() - Method in class org.apache.kafka.connect.header.ConnectHeaders
isEmpty() - Method in interface org.apache.kafka.connect.header.Headers: Determine whether this object has no headers.
isNext(String, boolean) - Method in class org.apache.kafka.connect.data.Values.Parser
isOptional() - Method in class org.apache.kafka.connect.data.ConnectSchema
isOptional() - Method in interface org.apache.kafka.connect.data.Schema
isOptional() - Method in class org.apache.kafka.connect.data.SchemaBuilder
isPrimitive() - Method in enum org.apache.kafka.connect.data.Schema.Type
iterator() - Method in class org.apache.kafka.connect.header.ConnectHeaders

K

kafkaClusterId() - Method in interface org.apache.kafka.connect.health.ConnectClusterDetails: Get the cluster ID of the Kafka cluster backing this Connect cluster.
kafkaOffset() - Method in class org.apache.kafka.connect.sink.SinkRecord
kafkaPartition() - Method in class org.apache.kafka.connect.connector.ConnectRecord
key() - Method in class org.apache.kafka.connect.connector.ConnectRecord
key() - Method in interface org.apache.kafka.connect.header.Header: The header's key, which is not necessarily unique within the set of headers on a Kafka message.
keySchema() - Method in class org.apache.kafka.connect.connector.ConnectRecord
keySchema() - Method in class org.apache.kafka.connect.data.ConnectSchema
keySchema() - Method in interface org.apache.kafka.connect.data.Schema: Get the key schema for this map schema.
keySchema() - Method in class org.apache.kafka.connect.data.SchemaBuilder

L

lastWithName(String) - Method in class org.apache.kafka.connect.header.ConnectHeaders
lastWithName(String) - Method in interface org.apache.kafka.connect.header.Headers: Return the last Header with the specified key.
LOGICAL_NAME - Static variable in class org.apache.kafka.connect.data.Date
LOGICAL_NAME - Static variable in class org.apache.kafka.connect.data.Decimal
LOGICAL_NAME - Static variable in class org.apache.kafka.connect.data.Time
LOGICAL_NAME - Static variable in class org.apache.kafka.connect.data.Timestamp

M

map(Schema, Schema) - Static method in class org.apache.kafka.connect.data.SchemaBuilder
mark() - Method in class org.apache.kafka.connect.data.Values.Parser

N

name() - Method in class org.apache.kafka.connect.data.ConnectSchema
name() - Method in class org.apache.kafka.connect.data.Field: Get the name of this field.
name() - Method in interface org.apache.kafka.connect.data.Schema
name() - Method in class org.apache.kafka.connect.data.SchemaBuilder
name(String) - Method in class org.apache.kafka.connect.data.SchemaBuilder: Set the name of this schema.
name() - Method in class org.apache.kafka.connect.health.ConnectorHealth: Provides the name of the connector.
newConfigDef() - Static method in class org.apache.kafka.connect.storage.ConverterConfig: Create a new ConfigDef instance containing the configurations defined by ConverterConfig.
newRecord(String, Integer, Schema, Object, Schema, Object, Long) - Method in class org.apache.kafka.connect.connector.ConnectRecord: Create a new record of the same type as itself, with the specified parameter values.
newRecord(String, Integer, Schema, Object, Schema, Object, Long, Iterable<Header>) - Method in class org.apache.kafka.connect.connector.ConnectRecord: Create a new record of the same type as itself, with the specified parameter values.
newRecord(String, Integer, Schema, Object, Schema, Object, Long) - Method in class org.apache.kafka.connect.sink.SinkRecord
newRecord(String, Integer, Schema, Object, Schema, Object, Long, Iterable<Header>) - Method in class org.apache.kafka.connect.sink.SinkRecord
newRecord(String, Integer, Schema, Object, Schema, Object, Long) - Method in class org.apache.kafka.connect.source.SourceRecord
newRecord(String, Integer, Schema, Object, Schema, Object, Long, Iterable<Header>) - Method in class org.apache.kafka.connect.source.SourceRecord
next() - Method in class org.apache.kafka.connect.data.Values.Parser
next(int) - Method in class org.apache.kafka.connect.data.Values.Parser
NotFoundException - Exception in org.apache.kafka.connect.errors: Indicates that an operation attempted to modify or delete a connector or task that is not present on the worker.
NotFoundException(String) - Constructor for exception org.apache.kafka.connect.errors.NotFoundException
NotFoundException(String, Throwable) - Constructor for exception org.apache.kafka.connect.errors.NotFoundException
NotFoundException(Throwable) - Constructor for exception org.apache.kafka.connect.errors.NotFoundException
NULL - Static variable in class org.apache.kafka.connect.data.SchemaAndValue

O

offset(Map<TopicPartition, Long>) - Method in interface org.apache.kafka.connect.sink.SinkTaskContext: Reset the consumer offsets for the given topic partitions.
offset(TopicPartition, long) - Method in interface org.apache.kafka.connect.sink.SinkTaskContext: Reset the consumer offsets for the given topic partition.
offset(Map<String, T>) - Method in interface org.apache.kafka.connect.storage.OffsetStorageReader: Get the offset for the specified partition.
offsets(Collection<Map<String, T>>) - Method in interface org.apache.kafka.connect.storage.OffsetStorageReader: Get a set of offsets for the specified partition identifiers.
offsetStorageReader() - Method in interface org.apache.kafka.connect.source.SourceConnectorContext: Returns the OffsetStorageReader for this SourceConnectorContext.
offsetStorageReader() - Method in interface org.apache.kafka.connect.source.SourceTaskContext: Get the OffsetStorageReader for this SourceTask.
OffsetStorageReader - Interface in org.apache.kafka.connect.storage: OffsetStorageReader provides access to the offset storage used by sources.
onPartitionsAssigned(Collection<TopicPartition>) - Method in class org.apache.kafka.connect.sink.SinkTask: Deprecated.
Use SinkTask.open(Collection) for partition initialization.
onPartitionsRevoked(Collection<TopicPartition>) - Method in class org.apache.kafka.connect.sink.SinkTask: Deprecated.
Use SinkTask.close(Collection) instead for partition cleanup.
open(Collection<TopicPartition>) - Method in class org.apache.kafka.connect.sink.SinkTask: The SinkTask use this method to create writers for newly assigned partitions in case of partition rebalance.
optional() - Method in class org.apache.kafka.connect.data.SchemaBuilder: Set this schema as optional.
OPTIONAL_BOOLEAN_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
OPTIONAL_BYTES_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
OPTIONAL_FLOAT32_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
OPTIONAL_FLOAT64_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
OPTIONAL_INT16_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
OPTIONAL_INT32_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
OPTIONAL_INT64_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
OPTIONAL_INT8_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
OPTIONAL_STRING_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
org.apache.kafka.connect.components - package org.apache.kafka.connect.components: Provides common interfaces used to describe pluggable components.
org.apache.kafka.connect.connector - package org.apache.kafka.connect.connector: Provides interfaces for Connector and Task implementations.
org.apache.kafka.connect.connector.policy - package org.apache.kafka.connect.connector.policy: Provides pluggable interfaces for policies controlling how users can configure connectors.
org.apache.kafka.connect.data - package org.apache.kafka.connect.data: Provides classes for representing data and schemas handled by Connect.
org.apache.kafka.connect.errors - package org.apache.kafka.connect.errors: Provides common exception classes for Connect, used by the framework and plugins to communicate failures.
org.apache.kafka.connect.header - package org.apache.kafka.connect.header: Provides an API for application-defined metadata attached to Connect records.
org.apache.kafka.connect.health - package org.apache.kafka.connect.health: Provides an API for describing the state of a running Connect cluster to ConnectRestExtension instances.
org.apache.kafka.connect.rest - package org.apache.kafka.connect.rest: Provides a pluggable interface for altering the behavior of the Connect REST API.
org.apache.kafka.connect.sink - package org.apache.kafka.connect.sink: Provides an API for implementing sink connectors which write Kafka records to external applications.
org.apache.kafka.connect.source - package org.apache.kafka.connect.source: Provides an API for implementing source connectors which read data from external applications into Kafka.
org.apache.kafka.connect.storage - package org.apache.kafka.connect.storage: Provides pluggable interfaces and some implementations for (de)serializing data to and from Kafka
org.apache.kafka.connect.transforms - package org.apache.kafka.connect.transforms: Provides a pluggable interface for altering data which is being moved by Connect.
org.apache.kafka.connect.transforms.predicates - package org.apache.kafka.connect.transforms.predicates: Provides a pluggable interface for describing when a Transformation should be applied to a record.
org.apache.kafka.connect.util - package org.apache.kafka.connect.util: Provides common utilities that can be used in component implementations.
original() - Method in class org.apache.kafka.connect.data.Values.Parser

P

parameter(String, String) - Method in class org.apache.kafka.connect.data.SchemaBuilder: Set a schema parameter.
parameters() - Method in class org.apache.kafka.connect.data.ConnectSchema
parameters() - Method in interface org.apache.kafka.connect.data.Schema: Get a map of schema parameters.
parameters() - Method in class org.apache.kafka.connect.data.SchemaBuilder
parameters(Map<String, String>) - Method in class org.apache.kafka.connect.data.SchemaBuilder: Set schema parameters.
parse(Values.Parser, boolean) - Static method in class org.apache.kafka.connect.data.Values
Parser(String) - Constructor for class org.apache.kafka.connect.data.Values.Parser
parseString(String) - Static method in class org.apache.kafka.connect.data.Values: Parse the specified string representation of a value into its schema and value.
pause(TopicPartition...) - Method in interface org.apache.kafka.connect.sink.SinkTaskContext: Pause consumption of messages from the specified TopicPartitions.
poll() - Method in class org.apache.kafka.connect.source.SourceTask: Poll this source task for new records.
position() - Method in class org.apache.kafka.connect.data.Values.Parser
preCommit(Map<TopicPartition, OffsetAndMetadata>) - Method in class org.apache.kafka.connect.sink.SinkTask: Pre-commit hook invoked prior to an offset commit.
Predicate<R extends ConnectRecord<R>> - Interface in org.apache.kafka.connect.transforms.predicates: A predicate on records.
previous() - Method in class org.apache.kafka.connect.data.Values.Parser
project(Schema, Object, Schema) - Static method in class org.apache.kafka.connect.data.SchemaProjector: This method project a value between compatible schemas and throw exceptions when non compatible schemas are provided
put(String, Object) - Method in class org.apache.kafka.connect.data.Struct: Set the value of a field.
put(Field, Object) - Method in class org.apache.kafka.connect.data.Struct: Set the value of a field.
put(Collection<SinkRecord>) - Method in class org.apache.kafka.connect.sink.SinkTask: Put the records in the sink.

R

raiseError(Exception) - Method in interface org.apache.kafka.connect.connector.ConnectorContext: Raise an unrecoverable exception to the Connect framework.
reconfigure(Map<String, String>) - Method in class org.apache.kafka.connect.connector.Connector: Reconfigure this Connector.
register(ConnectRestExtensionContext) - Method in interface org.apache.kafka.connect.rest.ConnectRestExtension: ConnectRestExtension implementations can register custom JAX-RS resources via the ConnectRestExtension.register(ConnectRestExtensionContext) method.
remove(String) - Method in class org.apache.kafka.connect.header.ConnectHeaders
remove(String) - Method in interface org.apache.kafka.connect.header.Headers: Removes all Header objects whose key matches the specified key.
rename(String) - Method in interface org.apache.kafka.connect.header.Header: Return a new Header object that has the same schema and value but with the supplied key.
report(SinkRecord, Throwable) - Method in interface org.apache.kafka.connect.sink.ErrantRecordReporter: Report a problematic record and the corresponding error to be written to the sink connector's dead letter queue (DLQ).
requestCommit() - Method in interface org.apache.kafka.connect.sink.SinkTaskContext: Request an offset commit.
requestTaskReconfiguration() - Method in interface org.apache.kafka.connect.connector.ConnectorContext: Requests that the runtime reconfigure the Tasks for this source.
required() - Method in class org.apache.kafka.connect.data.SchemaBuilder: Set this schema as required.
resume(TopicPartition...) - Method in interface org.apache.kafka.connect.sink.SinkTaskContext: Resume consumption of messages from previously paused TopicPartitions.
retainLatest() - Method in class org.apache.kafka.connect.header.ConnectHeaders
retainLatest(String) - Method in class org.apache.kafka.connect.header.ConnectHeaders
retainLatest(String) - Method in interface org.apache.kafka.connect.header.Headers: Removes all but the latest Header objects whose key matches the specified key.
retainLatest() - Method in interface org.apache.kafka.connect.header.Headers: Removes all but the last Header object with each key.
RetriableException - Exception in org.apache.kafka.connect.errors: An exception that indicates the operation can be reattempted.
RetriableException(String) - Constructor for exception org.apache.kafka.connect.errors.RetriableException
RetriableException(String, Throwable) - Constructor for exception org.apache.kafka.connect.errors.RetriableException
RetriableException(Throwable) - Constructor for exception org.apache.kafka.connect.errors.RetriableException
rewindTo(int) - Method in class org.apache.kafka.connect.data.Values.Parser

S

SCALE_FIELD - Static variable in class org.apache.kafka.connect.data.Decimal
schema() - Method in class org.apache.kafka.connect.data.ConnectSchema
SCHEMA - Static variable in class org.apache.kafka.connect.data.Date
schema(int) - Static method in class org.apache.kafka.connect.data.Decimal
schema() - Method in class org.apache.kafka.connect.data.Field: Get the schema of this field
Schema - Interface in org.apache.kafka.connect.data: Definition of an abstract data type.
schema() - Method in interface org.apache.kafka.connect.data.Schema: Return a concrete instance of the Schema
schema() - Method in class org.apache.kafka.connect.data.SchemaAndValue
schema() - Method in class org.apache.kafka.connect.data.SchemaBuilder: Return a concrete instance of the Schema specified by this builder
schema() - Method in class org.apache.kafka.connect.data.Struct: Get the schema for this Struct.
SCHEMA - Static variable in class org.apache.kafka.connect.data.Time
SCHEMA - Static variable in class org.apache.kafka.connect.data.Timestamp
schema() - Method in class org.apache.kafka.connect.data.Values.SchemaDetector
schema() - Method in interface org.apache.kafka.connect.header.Header: Return the Schema associated with this header, if there is one.
Schema.Type - Enum in org.apache.kafka.connect.data: The type of a schema.
SchemaAndValue - Class in org.apache.kafka.connect.data
SchemaAndValue(Schema, Object) - Constructor for class org.apache.kafka.connect.data.SchemaAndValue
SchemaBuilder - Class in org.apache.kafka.connect.data: SchemaBuilder provides a fluent API for constructing Schema objects.
SchemaBuilder(Schema.Type) - Constructor for class org.apache.kafka.connect.data.SchemaBuilder
SchemaBuilderException - Exception in org.apache.kafka.connect.errors
SchemaBuilderException(String) - Constructor for exception org.apache.kafka.connect.errors.SchemaBuilderException
SchemaBuilderException(String, Throwable) - Constructor for exception org.apache.kafka.connect.errors.SchemaBuilderException
SchemaBuilderException(Throwable) - Constructor for exception org.apache.kafka.connect.errors.SchemaBuilderException
SchemaDetector() - Constructor for class org.apache.kafka.connect.data.Values.SchemaDetector
SchemaProjector - Class in org.apache.kafka.connect.data: SchemaProjector is utility to project a value between compatible schemas and throw exceptions when non compatible schemas are provided.
SchemaProjector() - Constructor for class org.apache.kafka.connect.data.SchemaProjector
SchemaProjectorException - Exception in org.apache.kafka.connect.errors
SchemaProjectorException(String) - Constructor for exception org.apache.kafka.connect.errors.SchemaProjectorException
SchemaProjectorException(String, Throwable) - Constructor for exception org.apache.kafka.connect.errors.SchemaProjectorException
SchemaProjectorException(Throwable) - Constructor for exception org.apache.kafka.connect.errors.SchemaProjectorException
schemaType(Class<?>) - Static method in class org.apache.kafka.connect.data.ConnectSchema: Get the Schema.Type associated with the given class.
SimpleHeaderConverter - Class in org.apache.kafka.connect.storage: A HeaderConverter that serializes header values as strings and that deserializes header values to the most appropriate numeric, boolean, array, or map representation.
SimpleHeaderConverter() - Constructor for class org.apache.kafka.connect.storage.SimpleHeaderConverter
SinkConnector - Class in org.apache.kafka.connect.sink: SinkConnectors implement the Connector interface to send Kafka data to another system.
SinkConnector() - Constructor for class org.apache.kafka.connect.sink.SinkConnector
SinkConnectorContext - Interface in org.apache.kafka.connect.sink: A context to allow a SinkConnector to interact with the Kafka Connect runtime.
SinkRecord - Class in org.apache.kafka.connect.sink: SinkRecord is a ConnectRecord that has been read from Kafka and includes the kafkaOffset of the record in the Kafka topic-partition in addition to the standard fields.
SinkRecord(String, int, Schema, Object, Schema, Object, long) - Constructor for class org.apache.kafka.connect.sink.SinkRecord
SinkRecord(String, int, Schema, Object, Schema, Object, long, Long, TimestampType) - Constructor for class org.apache.kafka.connect.sink.SinkRecord
SinkRecord(String, int, Schema, Object, Schema, Object, long, Long, TimestampType, Iterable<Header>) - Constructor for class org.apache.kafka.connect.sink.SinkRecord
SinkTask - Class in org.apache.kafka.connect.sink: SinkTask is a Task that takes records loaded from Kafka and sends them to another system.
SinkTask() - Constructor for class org.apache.kafka.connect.sink.SinkTask
SinkTaskContext - Interface in org.apache.kafka.connect.sink: Context passed to SinkTasks, allowing them to access utilities in the Kafka Connect runtime.
size() - Method in class org.apache.kafka.connect.header.ConnectHeaders
size() - Method in interface org.apache.kafka.connect.header.Headers: Get the number of headers in this object.
SourceConnector - Class in org.apache.kafka.connect.source: SourceConnectors implement the connector interface to pull data from another system and send it to Kafka.
SourceConnector() - Constructor for class org.apache.kafka.connect.source.SourceConnector
SourceConnectorContext - Interface in org.apache.kafka.connect.source: A context to allow a SourceConnector to interact with the Kafka Connect runtime.
sourceOffset() - Method in class org.apache.kafka.connect.source.SourceRecord
sourcePartition() - Method in class org.apache.kafka.connect.source.SourceRecord
SourceRecord - Class in org.apache.kafka.connect.source: SourceRecords are generated by SourceTasks and passed to Kafka Connect for storage in Kafka.
SourceRecord(Map<String, ?>, Map<String, ?>, String, Integer, Schema, Object) - Constructor for class org.apache.kafka.connect.source.SourceRecord
SourceRecord(Map<String, ?>, Map<String, ?>, String, Schema, Object) - Constructor for class org.apache.kafka.connect.source.SourceRecord
SourceRecord(Map<String, ?>, Map<String, ?>, String, Schema, Object, Schema, Object) - Constructor for class org.apache.kafka.connect.source.SourceRecord
SourceRecord(Map<String, ?>, Map<String, ?>, String, Integer, Schema, Object, Schema, Object) - Constructor for class org.apache.kafka.connect.source.SourceRecord
SourceRecord(Map<String, ?>, Map<String, ?>, String, Integer, Schema, Object, Schema, Object, Long) - Constructor for class org.apache.kafka.connect.source.SourceRecord
SourceRecord(Map<String, ?>, Map<String, ?>, String, Integer, Schema, Object, Schema, Object, Long, Iterable<Header>) - Constructor for class org.apache.kafka.connect.source.SourceRecord
SourceTask - Class in org.apache.kafka.connect.source: SourceTask is a Task that pulls records from another system for storage in Kafka.
SourceTask() - Constructor for class org.apache.kafka.connect.source.SourceTask
SourceTask.TransactionBoundary - Enum in org.apache.kafka.connect.source: Represents the permitted values for the SourceTask.TRANSACTION_BOUNDARY_CONFIG property.
SourceTaskContext - Interface in org.apache.kafka.connect.source: SourceTaskContext is provided to SourceTasks to allow them to interact with the underlying runtime.
start(Map<String, String>) - Method in class org.apache.kafka.connect.connector.Connector: Start this Connector.
start(Map<String, String>) - Method in interface org.apache.kafka.connect.connector.Task: Start the Task
start(Map<String, String>) - Method in class org.apache.kafka.connect.sink.SinkTask: Start the Task.
start(Map<String, String>) - Method in class org.apache.kafka.connect.source.SourceTask: Start the Task.
state() - Method in class org.apache.kafka.connect.health.AbstractState: Provides the current state of the connector or task.
stop() - Method in class org.apache.kafka.connect.connector.Connector: Stop this connector.
stop() - Method in interface org.apache.kafka.connect.connector.Task: Stop this task.
stop() - Method in class org.apache.kafka.connect.sink.SinkTask: Perform any cleanup to stop this task.
stop() - Method in class org.apache.kafka.connect.source.SourceTask: Signal this SourceTask to stop.
string() - Static method in class org.apache.kafka.connect.data.SchemaBuilder
STRING_SCHEMA - Static variable in interface org.apache.kafka.connect.data.Schema
StringConverter - Class in org.apache.kafka.connect.storage: Converter and HeaderConverter implementation that only supports serializing to strings.
StringConverter() - Constructor for class org.apache.kafka.connect.storage.StringConverter
StringConverterConfig - Class in org.apache.kafka.connect.storage: Configuration options for StringConverter instances.
StringConverterConfig(Map<String, ?>) - Constructor for class org.apache.kafka.connect.storage.StringConverterConfig
struct() - Static method in class org.apache.kafka.connect.data.SchemaBuilder
Struct - Class in org.apache.kafka.connect.data: A structured record containing a set of named fields with values, each field using an independent Schema.
Struct(Schema) - Constructor for class org.apache.kafka.connect.data.Struct: Create a new Struct for this Schema

T

Task - Interface in org.apache.kafka.connect.connector: Tasks contain the code that actually copies data to/from another system.
taskClass() - Method in class org.apache.kafka.connect.connector.Connector: Returns the Task implementation for this Connector.
taskConfigs(int) - Method in class org.apache.kafka.connect.connector.Connector: Returns a set of configurations for Tasks based on the current configuration, producing at most count configurations.
taskId() - Method in class org.apache.kafka.connect.health.TaskState: Provides the ID of the task.
tasksState() - Method in class org.apache.kafka.connect.health.ConnectorHealth: Provides the current state of the connector tasks.
TaskState - Class in org.apache.kafka.connect.health: Describes the state, IDs, and any errors of a connector task.
TaskState(int, String, String, String) - Constructor for class org.apache.kafka.connect.health.TaskState: Provides an instance of TaskState.
test(R) - Method in interface org.apache.kafka.connect.transforms.predicates.Predicate: Returns whether the given record satisfies this predicate.
Time - Class in org.apache.kafka.connect.data: A time representing a specific point in a day, not tied to any specific date.
Time() - Constructor for class org.apache.kafka.connect.data.Time
timeout(long) - Method in interface org.apache.kafka.connect.sink.SinkTaskContext: Set the timeout in milliseconds.
timestamp() - Method in class org.apache.kafka.connect.connector.ConnectRecord
Timestamp - Class in org.apache.kafka.connect.data: A timestamp representing an absolute time, without timezone information.
Timestamp() - Constructor for class org.apache.kafka.connect.data.Timestamp
timestampType() - Method in class org.apache.kafka.connect.sink.SinkRecord
toConnectData(String, byte[]) - Method in interface org.apache.kafka.connect.storage.Converter: Convert a native object to a Kafka Connect data object.
toConnectData(String, Headers, byte[]) - Method in interface org.apache.kafka.connect.storage.Converter: Convert a native object to a Kafka Connect data object, potentially using the supplied topic and headers in the record as necessary.
toConnectData(String, byte[]) - Method in class org.apache.kafka.connect.storage.StringConverter
toConnectHeader(String, String, byte[]) - Method in interface org.apache.kafka.connect.storage.HeaderConverter: Convert the header name and byte array value into a Header object.
toConnectHeader(String, String, byte[]) - Method in class org.apache.kafka.connect.storage.SimpleHeaderConverter
toConnectHeader(String, String, byte[]) - Method in class org.apache.kafka.connect.storage.StringConverter
toLogical(Schema, int) - Static method in class org.apache.kafka.connect.data.Date
toLogical(Schema, byte[]) - Static method in class org.apache.kafka.connect.data.Decimal
toLogical(Schema, int) - Static method in class org.apache.kafka.connect.data.Time
toLogical(Schema, long) - Static method in class org.apache.kafka.connect.data.Timestamp
topic() - Method in class org.apache.kafka.connect.connector.ConnectRecord
TOPICS_CONFIG - Static variable in class org.apache.kafka.connect.sink.SinkConnector: Configuration key for the list of input topics for this connector.
TOPICS_CONFIG - Static variable in class org.apache.kafka.connect.sink.SinkTask: The configuration key that provides the list of topics that are inputs for this SinkTask.
TOPICS_REGEX_CONFIG - Static variable in class org.apache.kafka.connect.sink.SinkTask: The configuration key that provides a regex specifying which topics to include as inputs for this SinkTask.
toString() - Method in class org.apache.kafka.connect.connector.ConnectRecord
toString() - Method in class org.apache.kafka.connect.data.ConnectSchema
toString() - Method in class org.apache.kafka.connect.data.Field
toString() - Method in class org.apache.kafka.connect.data.SchemaAndValue
toString() - Method in class org.apache.kafka.connect.data.Struct
toString() - Method in class org.apache.kafka.connect.header.ConnectHeaders
toString() - Method in class org.apache.kafka.connect.health.ConnectorHealth
toString() - Method in class org.apache.kafka.connect.health.ConnectorState
toString() - Method in enum org.apache.kafka.connect.health.ConnectorType
toString() - Method in class org.apache.kafka.connect.health.TaskState
toString() - Method in class org.apache.kafka.connect.sink.SinkRecord
toString() - Method in class org.apache.kafka.connect.source.SourceRecord
toString() - Method in enum org.apache.kafka.connect.source.SourceTask.TransactionBoundary
traceMessage() - Method in class org.apache.kafka.connect.health.AbstractState: The error message associated with the connector or task.
TRANSACTION_BOUNDARY_CONFIG - Static variable in class org.apache.kafka.connect.source.SourceTask: The configuration key that determines how source tasks will define transaction boundaries when exactly-once support is enabled.
transactionContext() - Method in interface org.apache.kafka.connect.source.SourceTaskContext: Get a TransactionContext that can be used to define producer transaction boundaries when exactly-once support is enabled for the connector.
TransactionContext - Interface in org.apache.kafka.connect.source: Provided to source tasks to allow them to define their own producer transaction boundaries when exactly-once support is enabled.
Transformation<R extends ConnectRecord<R>> - Interface in org.apache.kafka.connect.transforms: Single message transformation for Kafka Connect record types.
type() - Method in class org.apache.kafka.connect.data.ConnectSchema
type() - Method in interface org.apache.kafka.connect.data.Schema
type() - Method in class org.apache.kafka.connect.data.SchemaBuilder
type(Schema.Type) - Static method in class org.apache.kafka.connect.data.SchemaBuilder: Create a SchemaBuilder for the specified type.
type() - Method in class org.apache.kafka.connect.health.ConnectorHealth: Provides the type of the connector.
type() - Method in class org.apache.kafka.connect.storage.ConverterConfig: Get the type of converter as defined by the ConverterConfig.TYPE_CONFIG configuration.
TYPE_CONFIG - Static variable in class org.apache.kafka.connect.storage.ConverterConfig

V

validate(Map<String, String>) - Method in class org.apache.kafka.connect.connector.Connector: Validate the connector configuration values against configuration definitions.
validate(ConnectorClientConfigRequest) - Method in interface org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy: Worker will invoke this while constructing the producer for the SourceConnectors, DLQ for SinkConnectors and the consumer for the SinkConnectors to validate if all of the overridden client configurations are allowed per the policy implementation.
validate() - Method in class org.apache.kafka.connect.data.Struct: Validates that this struct has filled in all the necessary data with valid values.
validateValue(Schema, Object) - Static method in class org.apache.kafka.connect.data.ConnectSchema: Validate that the value can be used with the schema, i.e.
validateValue(String, Schema, Object) - Static method in class org.apache.kafka.connect.data.ConnectSchema
validateValue(Object) - Method in class org.apache.kafka.connect.data.ConnectSchema: Validate that the value can be used for this schema, i.e.
value() - Method in class org.apache.kafka.connect.connector.ConnectRecord
value() - Method in class org.apache.kafka.connect.data.SchemaAndValue
value() - Method in interface org.apache.kafka.connect.header.Header: Get the header's value as deserialized by Connect's header converter.
valueOf(String) - Static method in enum org.apache.kafka.connect.connector.policy.ConnectorClientConfigRequest.ClientType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kafka.connect.data.Schema.Type: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kafka.connect.health.ConnectorType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kafka.connect.source.ConnectorTransactionBoundaries: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kafka.connect.source.ExactlyOnceSupport: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kafka.connect.source.SourceTask.TransactionBoundary: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.kafka.connect.storage.ConverterType: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.kafka.connect.connector.policy.ConnectorClientConfigRequest.ClientType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kafka.connect.data.Schema.Type: Returns an array containing the constants of this enum type, in the order they are declared.
Values - Class in org.apache.kafka.connect.data: Utility for converting from one Connect value to a different form.
Values() - Constructor for class org.apache.kafka.connect.data.Values
values() - Static method in enum org.apache.kafka.connect.health.ConnectorType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kafka.connect.source.ConnectorTransactionBoundaries: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kafka.connect.source.ExactlyOnceSupport: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kafka.connect.source.SourceTask.TransactionBoundary: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.kafka.connect.storage.ConverterType: Returns an array containing the constants of this enum type, in the order they are declared.
Values.Parser - Class in org.apache.kafka.connect.data
Values.SchemaDetector - Class in org.apache.kafka.connect.data
valueSchema() - Method in class org.apache.kafka.connect.connector.ConnectRecord
valueSchema() - Method in class org.apache.kafka.connect.data.ConnectSchema
valueSchema() - Method in interface org.apache.kafka.connect.data.Schema: Get the value schema for this map or array schema.
valueSchema() - Method in class org.apache.kafka.connect.data.SchemaBuilder
version() - Method in interface org.apache.kafka.connect.components.Versioned: Get the version of this component.
version() - Method in interface org.apache.kafka.connect.connector.Task: Get the version of this task.
version() - Method in class org.apache.kafka.connect.data.ConnectSchema
version() - Method in interface org.apache.kafka.connect.data.Schema: Get the optional version of the schema.
version() - Method in class org.apache.kafka.connect.data.SchemaBuilder
version(Integer) - Method in class org.apache.kafka.connect.data.SchemaBuilder: Set the version of this schema.
Versioned - Interface in org.apache.kafka.connect.components: Connect requires some components implement this interface to define a version string.

W

with(Schema, Object) - Method in interface org.apache.kafka.connect.header.Header: Return a new Header object that has the same key but with the supplied value.
withName(String) - Static method in enum org.apache.kafka.connect.storage.ConverterType: Find the ConverterType with the given name, using a case-insensitive match.
workerId() - Method in class org.apache.kafka.connect.health.AbstractState: The identifier of the worker associated with the connector or the task.

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