Table of Contents

Namespace Org.Apache.Kafka.Connect.Source

Classes

ConnectorTransactionBoundaries

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/source/ConnectorTransactionBoundaries.html

ExactlyOnceSupport

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/source/ExactlyOnceSupport.html

SourceConnector

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/source/SourceConnector.html

SourceConnectorContext

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/source/SourceConnectorContext.html

SourceRecord

SourceRecord are generated by KNetSourceTask<TTask> and passed to Kafka Connect for storage in Kafka. In addition to the standard fields in ConnectRecord<R, TKey, TValue> which specify where data is stored in Kafka, they also include a sourcePartition and sourceOffset.

SourceRecord<TKey, TValue>

SourceRecord<TKey, TValue> are generated by KNetSourceTask<TTask> and passed to Kafka Connect for storage in Kafka. In addition to the standard fields in ConnectRecord<R, TKey, TValue> which specify where data is stored in Kafka, they also include a sourcePartition and sourceOffset.

SourceRecord<TKeySource, TOffset, TKey, TValue>

SourceRecord<TKey, TValue> are generated by KNetSourceTask<TTask> and passed to Kafka Connect for storage in Kafka. In addition to the standard fields in ConnectRecord<R, TKey, TValue> which specify where data is stored in Kafka, they also include a sourcePartition and sourceOffset.

SourceTask

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/source/SourceTask.html

SourceTask.TransactionBoundary

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/source/SourceTask.TransactionBoundary.html

SourceTaskContext

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/source/SourceTaskContext.html

TransactionContext

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.9.0/org/apache/kafka/connect/source/TransactionContext.html

Interfaces

ISourceConnectorContext

.NET interface for TO BE DEFINED FROM USER

ISourceTaskContext

.NET interface for TO BE DEFINED FROM USER

ITransactionContext

.NET interface for TO BE DEFINED FROM USER