Table of Contents

Namespace Org.Apache.Kafka.Connect.Util

Classes

Callback

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/Callback.html

Callback<V>

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/Callback.html

ConcreteSubClassValidator

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/ConcreteSubClassValidator.html

ConnectUtils

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/ConnectUtils.html

ConnectorTaskId

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/ConnectorTaskId.html

ConnectorUtils

https://www.javadoc.io/doc/org.apache.kafka/connect-api/4.0.0/org/apache/kafka/connect/util/ConnectorUtils.html

ConvertingFutureCallback

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/ConvertingFutureCallback.html

ConvertingFutureCallback<U, T>

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/ConvertingFutureCallback.html

FutureCallback

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/FutureCallback.html

FutureCallback<T>

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/FutureCallback.html

InstantiableClassValidator

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/InstantiableClassValidator.html

KafkaBasedLog

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/KafkaBasedLog.html

KafkaBasedLog<K, V>

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/KafkaBasedLog.html

LoggingContext

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/LoggingContext.html

LoggingContext.Scope

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/LoggingContext.Scope.html

RetryUtil

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/RetryUtil.html

SafeObjectInputStream

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/SafeObjectInputStream.html

SinkUtils

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/SinkUtils.html

Stage

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/Stage.html

StagedTimeoutException

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/StagedTimeoutException.html

Table

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/Table.html

Table<R, C, V>

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/Table.html

TemporaryStage

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/TemporaryStage.html

TopicAdmin

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/TopicAdmin.html

TopicAdmin.NewTopicBuilder

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/TopicAdmin.NewTopicBuilder.html

TopicAdmin.TopicCreationResponse

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/TopicAdmin.TopicCreationResponse.html

TopicCreation

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/TopicCreation.html

TopicCreationGroup

https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/TopicCreationGroup.html

Interfaces

ICallback<V>

.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/connect-runtime/4.0.0/org/apache/kafka/connect/util/Callback.html